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を次のように置き換えると、スレッドベースのクラスをそのままにしておくことができます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 に答える