gevent

    3熱度

    1回答

    我用燒瓶+ gevent構建我的服務器,但名爲'getall'的gevent被燒瓶阻塞,所以'getall'函數無法在此代碼中打印消息。猴子補丁正在使用中。 import time import WSGICopyBody from flask import Flask import gevent def handle_node_request() : while True :

    0熱度

    1回答

    我有一個基本的生產者/消費者腳本在gevent中運行。它開始是把東西放到一個gevent.queue.Queue幾個生產函數,而取出來再排隊的一個消費函數: from __future__ import print_function import time import gevent import gevent.queue import gevent.monkey q = geve

    0熱度

    1回答

    這是我正在尋找。 s = Session() s.get(url, callback=self.do_this) def do_this(self, response): print response.url

    0熱度

    1回答

    消息這是我的代碼: class FirstNamespace(BaseNamespace): def on_some_event(self, msg): self.emit('ok '+msg) @app.route('/socket.io/<path:remaining>') # socket.io endpoint def socketio_withpath(rem

    0熱度

    1回答

    像下面的代碼一樣,在gevent.event.AsyncResult中很容易發送值到不同的協程。 import gevent from gevent.event import AsyncResult a = AsyncResult() def f1(): gevent.sleep(3) a.set('Hello') def f2(): print a.ge

    -1熱度

    1回答

    我正在使用python燒瓶建立一個站點。當它混淆了我,我在這裏展示我的處境不佳: ... @app.route('/wanted_delay_response') def delay_response(): def background_work(): # I want to check some flags in the background # this

    0熱度

    2回答

    我在我的應用程序中一起使用python 3.4和sqlalchemy以及pymsql和gevent和celery。有時在sql數據庫調用期間,會發生以下錯誤,不知道爲什麼會發生。有任何想法嗎? [2015-09-24 15:19:32,790: ERROR/Worker-1] Exception during reset or similar Traceback (most recent cal

    0熱度

    1回答

    與gevent.Timeout(0.1)爲TT: time.sleep(1) 以上,不會引起異常 與gevent.Timeout(0.1)爲TT: gevent.sleep(1) 拋gevent.timeout.Timeout:0.1秒 有差別time.sleep()和gevent.sleep()!

    3熱度

    1回答

    我需要加載約100k文件與載體和聚合內容在一個numpy數組。這個過程大約需要3分鐘,所以我想加快速度。我試圖用gevent來加速它,但我無法獲得任何加速。 我讀到應該使用異步調用來加速IO調用而不是多處理。我進一步閱讀gevent是推薦的圖書館。我寫了一個例子來下載圖片,我可以看到速度的巨大提高。這裏是我的代碼 def chunks(l, n): """ Yield successiv

    3熱度

    1回答

    我有一個由Gunicorn服務器使用異步工作者類(即gevent)服務的python應用程序(基於MVC模式)。這意味着多個客戶端請求由工作進程同時提供。 每個http請求都包含一些特定於該請求的數據,如'user_id'。假設模型發生錯誤,我想用user_id記錄 錯誤。我不想繼續向每個類或方法傳遞user_id(以及更多的請求特定值)。我希望這些值在全球範圍內可用於針對此特定請求執行的任何代碼