1

2つの異なる接続からデータを受信する2つの関数があり、一方から結果を取得した後、両方の接続を閉じる必要があります。

def first():
    gevent.sleep(randint(1, 100))  # i don't know how much time it will work
    return 'foo'

def second():
    gevent.sleep(randint(1, 100))  # i don't know how much time it will work
    return 'bar'

次に、各関数を生成します。

lst = [gevent.spawn(first), gevent.spawn(second)]

gevent.joinallからの2つのグリーンレットの両方の準備ができるまで、現在のグリーンレットをブロックしlstます。

gevent.joinall(lst)  # wait much time
print lst[0].get(block=False)   # -> 'foo'
print lst[1].get(block=False)   # -> 'bar'

最初または2番目のグリーンレットの準備が整うまで待ちたい：

i_want_such_function(lst)  # returns after few seconds
print lst[0].get(block=False)  # -> 'foo' because this greenlet is ready
print lst[1].get(block=False)  # -> raised Timeout because this greenlet is not ready

どうすればいいですか？

4

2 に答える 2

4

次のように、gevent.event.Event（またはAsyncResult）とGreenletのlink（）メソッドを使用できます。

...
ready = gevent.event.Event()
ready.clear()

def callback():
    ready.set()

lst = [gevent.spawn(first), gevent.spawn(second)]
for g in lst:
    g.link(callback)

ready.wait()
...
于 2012-11-28T09:40:37.650 に答える
0

コールバックはgevent子プロセスを受け取り、そこから戻り値を取得できます。

...

cars = []

def _callback(job):
    cars.append(job.value)

for car in xml_all_cars:
    print "creating jobs"
    g_parse = Greenlet.spawn(myMainFunction)
    g_parse.start()
    g_parse.link(_callback)
    jobs.append(g_parse)

print "starting all jobs"
gevent.joinall(jobs)
print "jobs done"

return cars

車には、myMainFunctionが返すすべての値のリストがあります（すべての車について）

于 2015-05-11T14:42:11.430 に答える