Czy to jest bezpieczne w python?

Question

Nie mogę zdecydować, czy następujący deque jest bezpieczny dla wątków.
W skrócie, utworzyłem klasę z deque, która wyświetla jej zawartość co 1 sekundę w nowym wątku (więc nie wstrzyma programu głównego podczas drukowania).
Deque jest wypełniony z głównego wątku, więc w zasadzie POWINNA być szansa na kolizję.
JEDNAK, deque jest wypełniana przy użyciu metody klasy, więc zasadniczo jest dostępna z poziomu samej instancji, a więc z tego samego wątku.
Oto uproszczony kod:

import threading 
import time 
from collections import deque 

class MyQueue(threading.Thread): 
    def __init__(self): 
     threading.Thread.__init__(self) 
     self.q = deque() 
     self.start() 

    def run(self): 
     # pop out queue items every 1 sec 
     # (please ignore empty deque for now) 
     while True: 
      print self.q.popleft() 
      time.sleep(1) 

    def add_to_q(self, val): 
     # this function is called from outside 
     self.q.append(val) 

# main 
# fill the queue with values 
qu = MyQueue() 
for i in range(1:100): 
    qu.add_to_q(i) 

Tak, chociaż dodawanie i usuwanie elementów z kolejki odbywać wewnątrz instancji, to istnieje ryzyko, ze względu na funkcję dodawania miano spoza instancji?

EDYTOWANIE:
Ponieważ potrzebuję zmodyfikować elementy w mojej deque, musiałem użyć Deque. To, co robię, to: roatować() do danego elementu, wyskakuj, zmodyfikuj, wepchnij z powrotem i obróć() z powrotem do pierwotnej pozycji.
ile znajdę sposób wdrażania elementów modyfikujących w kolejce, muszę trzymać się deque

Answer 1

deque jest thread-safe (http://docs.python.org/library/collections.html#deque-objects) dla Dołącza i wyskakuje z przeciwnych stron. Beneath here, docs tylko wspomnieć, że append() i popleft() są wątkowo bezpieczne.

Istnieje kolejna implementacja samej kolejki. Powinieneś go używać, chyba że masz jakieś dziwne wymagania.

Answer 2

Moduł Queue może być przydatna dla Ciebie: http://docs.python.org/library/queue.html

Answer 3

Więcej informacji znajduje się odwoływać za bilet Python deque wątku bezpieczeństwa (https://bugs.python.org/issue15329).

Tytuł "wyjaśnienie, jakie deque metody są thread-safe", dolna linia:

dołączyć deque jest(), appendleft(), pop(), popleft() i len (d) operacje są wątkowo bezpieczne w CPython. Metody Append mają DECREF na końcu (w przypadkach, gdy maxlen zostało ustawione), ale to dzieje się po wszystkich zmianach struktury zostały dokonane i niezmienniki zostały przywrócone, więc jest w porządku, aby traktować te operacje jako atomowy.

W każdym razie, jeśli nie jesteś w 100% pewien i wolisz niezawodność nad wydajności, wystarczy umieścić jak Lock na print self.q.popleft() i self.q.append(val);)