python-asyncio

1熱

3答えて

私は非同期プログラミングの例をpythonで説明しようとしていましたが、失敗しました。ここに私のコードです。 Foo asyncFoo を10秒の待ち時間でasyncFooが表示されていた前に： import asyncio import time async def asyncfoo(t): time.sleep(t) print("asyncFoo")

0熱

1答えて

長いジョブでasyncio.ensure_futureを使用するのはなぜですか？

私はapiからjsonsをダウンロードしていて、asyncioモジュールを使っています。すでに作成され、それが利用可能なダウンローダオブジェクトを持っているので、それぞれを呼び出すクラスのこのインスタンスメソッド、のように実装 loop = asyncio.get_event_loop() main_task = asyncio.ensure_future(klass.download_all(

4熱

2答えて

Pythonで非同期ジェネレータを作成するには？

私は新しい非同期世界秩序にこのPython2.7コードを書き換えるしようとしている：すべての結果が計算されているので、私はその意志非同期実装としてこれを書き換えしようとしているまで def get_api_results(func, iterable): pool = multiprocessing.Pool(5) for res in pool.map(func, itera

1熱

1答えて

Python asyncioキューが更新されない

次のコードは、asyncio.Queueオブジェクトをインスタンス化し、このキューを2つの異なるコルーチン（arrival()およびserver()）から生成して消費しようとします。 loop = asyncio.get_event_loop() q = asyncio.Queue() async def arrival(q): print('ARRIVAL - Queue id:

0熱

1答えて

SQLAlchemyデータの接続が一貫していない

私は、両方ともFlask-SQLAlchemyを使用してsqliteデータベースにアクセスする2つのpythonアプリケーション（別々のプロセス）を持っています。そのうちの1つはasyncioモジュールを使用して設定されています（ただしFlaskアプリです）。もう1つはFlask-RESTful APIです。 Flask-RESTful APIによってデータベースに書き込まれたデータがasynci

2熱

1答えて

asyncioはGILを考慮してスレッドセーフではありません。

asyncio docs読む：ほとんどasyncioオブジェクトはスレッドセーフではありません。イベントループの外側にあるオブジェクトにアクセスする場合のみ心配する必要があります。誰かがこれを説明したり、asyncioの悪用がスレッド間で共有されるオブジェクトへの非同期書き込みを引き起こす例を挙げることができますか？ GILは、一度に1つのスレッドしかインタープリタを実行できないため、インタプ

1熱

2答えて

待ち

は、私は2つの非同期発電機を持っていると言う： async def get_rules(): while True: yield 'rule=1' asyncio.sleep(2) async def get_snapshots(): while True: yield 'snapshot=1' asyncio.sleep(