gevent, способы запуска запуска новых задач spawn

Question

В моем проекте используется gevnet, что для меня ново, для реализации бережливого сервера.

Я читаю код и изучаю его документ. Ниже приведен фрагмент кода в моем проекте:

TSocket.socket = gevent.socket # I find this when comparing the production 
           # code and mine. It seems that this socket 
           # schedule the tasks when there are newly-spawn ones. 
           # Could someone tell me more about it? 

while True: 
    try: 
     client = self.serverTransport.accept() 
     gevent.spawn(self._serve_client, client) 
    except (SystemExit, KeyboardInterrupt): 
     break 
    except Exception as x: 
     logging.exception(x) 

После нереста он непосредственно заканчивает работу здесь.

Но в моей собственной реализации, которая является для самостоятельного обучения, я должен сделать следующее:

while True: 
    try: 
     client = self.serverTransport.accept() 
     gevent.spawn(self._serve_client, client) 
     gevent.sleep(0) # switch to the newly-spawn task. 
         # this makes it to process tasks one by one and 
         # this makes it non-concurrent 
    except (SystemExit, KeyboardInterrupt): 
     break 
    except Exception as x: 
     logging.exception(x) 

В моем производстве код, я не нашел ни малейшего представления о том, как запускать задачи на запустить. Итак, я прошу здесь немного рассказать о способах запуска новых задач на сервере выше.

Answer 1

В вашем коде необходимо позвонить gevent.sleep(0), потому что ничего другого не запускает цикл gevent. Наличие этого сна дает управление обратно gevent, который выполняет порожденную озелени.

Строка TSocket.socket = gevent.socket в производственном коде исправляет ошибкупо умолчанию, чтобы использовать вместо gevent; gevent сокеты запускают цикл gevent, поэтому вам действительно нужен этот патч для запуска вашего кода.

Без патча TSocket.socket блокирует и убивает параллелизм (без потоков уровня ОС).