Запуск двух бесконечных параллельных петель

Question

Я хочу запустить две бесконечные параллельные петли. Один считывает данные с сервера и обновляет объект с помощью номера. Другой ничего не делает, а затем читает его и в случае изменения обрабатывает его. Не нужно синхронизировать или так. Поэтому я задаю следующие вопросы:

• В случае написания с одной стороны и чтения от другого, у Python есть проблемы с ним?
• В случае возникновения проблемы с синхронизацией мне нужно заблокировать процессы чтения/записи? Любой другой способ Я должен это сделать?
• Что лучше всего использовать, резьбу или резьбу?
• В качестве следующего шага я буду читать 100 сайтов и обновлять 100 объектов, и читать из 100 циклов для изменений. Рекомендуется ли использовать Multiprocessing с начала , чтобы я мог масштабироваться без проблем? Нужно ли мне при чтении и записи?

Любая помощь приветствуется.

Answer 1

Короткий ответ: все, что вы думаете, будет понятно для вас. Смысл, ваш код должен иметь смысл для вас в целях обучения.

Вот пример, легкий и простой в использовании. Получение значения из и нити легко .. Это не актуально многопоточность Тхо (одно ядро ​​CPU)

from threading import * 

class worker(Thread): 
    def __init__(self, input=0): 
     self.input = input 
     Thread.__init__(self) 
     self.start() 

    def run(self): 
     while 1: 
      self.input += 1 

x = worker(-100) 
y = worker(x.input) 

print y.input 

Это просто пример, чтобы показать, что Y нить может получить доступ к данным в x. на практике это может быть опасно, учитывая, что оба потока будут обновлять одну и ту же переменную :) (Короче говоря: -100 будет рассчитываться два раза за цикл, -98, -96, -94 и т. д.)

• Не будет охватывать несколько процессоров
• Easy (доступ к данным по потокам прост)
• Логический код, если вы не знакомы с системами очередей или распределенными системами
• Возникнет ошибка, если ОС не сможет создать больше потоков («ограничение»)

Answer 2

from threading import Thread 
from Queue import Queue 

class producer(Thread): 
    def __init__(self,queue): 
     Thread.__init__(self) 
     self.queue=queue 
     self.start() 
    def run(self): 
     while 1: 
      self.queue.put(update_value()) 

class consumer(Thread): 
    def __init__(self,queue): 
     Thread.__init__(self) 
     self.queue=queue 
     self.start() 
    def run(self): 
     while True: 
      value = queue.get() 
      do_whatever_you_want(value) 
queue = Queue() 
producer(queue) 
consumer(queue) 

обратите внимание, что вы можете масштабировать с помощью 100 производителя и одного потребителя (и, конечно, один очереди) 100 нитей должно быть в порядке, но все было бы иначе, если вы хотите 10000