gevent

0熱

1答えて

geventを使用しても、それは同期しており、実行時間は減少しません。 %timeit synchronous()と%timeit asynchronous()を比較することにより def fun(i): p = subprocess.Popen(['./main', 'data.txt'], stdout=PIPE, stderr=PIPE) err = p.communic

1熱

1答えて

Flask + SocketIO + GeventでSSL EOFエラーが発生するのはなぜですか？

これは私が持っている問題を一貫して繰り返す簡単なコードスニペットです。私はPython 2.7.12、Flask 0.11、Flask-SocketIO 2.7.1、およびgevent 1.1.2を使用しています。私はこれがおそらく責任パッケージのメーリングリストに持ち込まれた問題だと理解していますが、どちらが責任あるのか分かりません。しかし、私はそれが例外を発生させる理由で、geventの問題で

0熱

1答えて

Gevent：2つのコンシューマと2つのコンシューマを同時に使用しないでキューを使用する

コンシューマによって生成された値をディスクに書き込む必要があるという問題があります。私は毎回書くためにファイルの新しいインスタンスを開きたくないので、2番目のキューと他のコンシューマを使って1枚のGreenletからディスクに書き込むことを考えました。私のコードの問題は、2番目のキューが最初のキューから非同期で消費されないということです。最初のキューが最初に終了し、次に2番目のキューが消費されます

0熱

1答えて

gevent（cffi）設定に関する混乱

Gevent 1.1には、cythonとcffiの2つのバックエンドがあります。私が混乱するのは_corecffi_build.pyです。 line 331で、 ffi.set_source('gevent._corecffi', _source, include_dirs=include_dirs) ffi.set_sourceは、関連するCファイルをインクルードする源を指定していない理由

13熱

1答えて

マルチスレッドでのPythonリクエスト

私は過去2日間マルチスレッド機能を備えたスクレーパーを構築しようとしていました。どういうわけか私はまだそれを管理することができませんでした。最初はスレッディングモジュールで通常のマルチスレッドアプローチを試みましたが、シングルスレッドを使用するよりも速くはありませんでした。後でリクエストがブロックされ、マルチスレッドアプローチが実際には機能していないことがわかりました。だから、私は研究を続けて、グ

1熱

1答えて

Python：応答コードを返すのはいつですか？

私はユーザー入力を受け入れ、背中に多くの処理を行うAPIを持っています。私の質問は、入力検証後に応答コード（200）を返すべきか、入力処理（mysqlへの保存、入力の書式設定、redisへの保存など）が終了するまで待つべきですか？サンプルコードは： # Should I wait for the greenlets to finish processing - which might take

0熱

2答えて

Geventハブはgeventプールを実行して、プール

に例外を発生させてくれjoinに次の例外を提供します：リターンgreenlet.switch（自己） gevent.hub.LoopExit：（ 'この操作は永遠にブロックされます」、0x105cbd190選択デフォルト保留中のハブは、= = 0）コード0 refは次のとおりです。 queue = gevent.queue.Queue(items=range(5)) pool = g

7熱

1答えて

JoinableQueueのセロリ等価

セロリはmultiprocessing.JoinableQueue（またはgevent.queue.JoinableQueue）に相当しますか？私が探している機能は、キュー内のすべてのタスクが完了するのを待って、パブリッシャからセロリタスクキュー.join()にアクセスできることです。待ち行列がワーカー自身によって動的に満杯になるので、最初の待ちであるAsyncResultまたはGroupRe

0熱

1答えて

なぜgeventはダウンロード要求をスピードアップできますか？

私はrequests.getがブロックであるべきだと思うので、runとrun2の間に違いはないはずです。 import sys import gevent import requests from gevent import monkey monkey.patch_all() def download(): requests.get('http://www.baidu.com

1熱

2答えて

gevent monkey patching order

私たちはgeventを使っていくつかの非同期サーバーを作成しています。他のモジュールとの関係でmonkey patchingを実行するタイミングについてはいくつかの議論があります。 geentドキュメンテーションは次のようなものを示しています： from gevent import monkey monkey.patch_socket() import socket ライブラリモジュールを