26

我正在使用gevent，我正在修补所有内容。
似乎猴子修补会导致线程连续工作。

我的代码：

import threading
from gevent import monkey; monkey.patch_all()

class ExampleThread(threading.Thread):
    def run(self):
        do_stuff()  # takes a few minutes to finish
        print 'finished working'

if __name__ == '__main__':
    worker = ExampleThread()
    worker.start()
    print 'this should be printed before the worker finished'

所以线程没有按预期工作。
但是，如果我删除monkey.patch_all()它，它工作正常。
问题是我需要monkey.patch_all()使用 gevent （现在显示在上面的代码中）

我的解决方案：

我改变了

monkey.patch_all()

至

monkey.patch_all(thread=False)

所以我没有修补线程。

4

2 回答 2

32

当线程在 gevent 中被猴子修补时，它们表现为协程。这意味着您必须显式地让出控制权以使其他协程能够执行。

做到这一点的方法是调用已修补的阻塞操作（这将自动产生）或gevent.sleep：

#!/usr/bin/env python
from gevent import monkey, sleep
monkey.patch_all()
import threading

class ExampleThread(threading.Thread):
    def run(self):
        for i in xrange(10):
            print 'working'
            sleep()

if __name__ == '__main__':
    worker = ExampleThread()
    worker.start()
    print 'this will be printed after the first call to sleep'
于 2012-02-08T12:02:48.173 回答
0

Thread如果您用with替换，您可以保留基于 Thread 的类Greenlet，例如：

from gevent import monkey
from gevent import Greenlet
from threading import Thread


class ThreadLikeGreenlet(Greenlet):
    def __init__(self, name=None, target=None, args=(), kwargs=()):
        super().__init__(target, *args, **dict(kwargs))
        self.name = name

def is_gevent_patched():
    return monkey.is_module_patched('threading')

if is_gevent_patched():
    Thread = ThreadLikeGreenlet  # substitute Thread with Greenlet

class ExampleThread(Thread):
    ...

它将按您的意愿工作。

于 2018-06-07T22:27:26.023 回答