concurrent.futures

0熱

1答えて

pandas DataFrameの複数の列に並列に関数を適用する方法

何十万行ものpandas DataFrameがあり、そのDataFrameの複数の列にパラレルで時間のかかる関数を適用したいと考えています。 私は関数を連続的に適用する方法を知っています。たとえば： import hashlib import pandas as pd df = pd.DataFrame( {'col1': range(100_000), 'col2': rang

python pandas concurrent.futures 2017-12-08

---

1熱

1答えて

なぜconcurrent.futures.ProcessPoolExecutorのパフォーマンスが非常に低いですか？

をPython3に利用しようとすると、大きな行列を並行して処理しようとしています。コードの一般的な構造は以下の通りである： class X(object): self.matrix def f(self, i, row_i): <cpu-bound process> def fetch_multiple(self, ids): with ProcessPoolExe

python-3.x threadpool python-multithreading concurrent.futures process-pool 2017-08-31

---

3熱

1答えて

Python 2.7には、Goの `time.Tick`やNettyの` HashedWheelTimer`に類似したものがありますか？

私は正確な周期的メソッド呼び出しに依存する多くのコードを書いています。 Iランタイムのスレッドプールへの呼び出しを提出するPythonのfuturesライブラリを使用し、ループ内で呼び出しの間眠ってきた： executor = ThreadPoolExecutor(max_workers=cpu_count()) def remote_call(): # make a synchro

python python-2.7 go python-asyncio concurrent.futures 2017-10-25

---

0熱

2答えて

scala.concurrent.Future [play.api.mvc.Result] required：play.api.mvc.Result

（1）DBから値を取得しようとするAction.asyncが必要です。 DBが利用できない場合、別のリソースに接続しようとし、（2）そこから値を取得します。私が使用している2つのリソースがFutureを返すので、私は "recover"キーワードでそれらを分離しています。私はそれが最善の方法であるかどうかわからないです.....しかし、回復{}内の文は、型の不一致エラーがあります。 def sho

scala concurrent.futures playframework-2.6 2017-12-17

---

0熱

1答えて

マルチプロセスとプロセスをconcurrent.future._base.Futureで統合する

私は子プロセスを作成し、Futureを使用して結果を受け取って、必要なときにそれらの一部を強制終了するという要件があります。 私はこれをサブクラス化し、multiprocessing.Processクラスを作成し、start（）メソッドからFutureオブジェクトを返します。 問題は、決して呼び出されないので、私はcb（）関数で結果を受け取ることができないということです。 私の現在の実装ではこれが

python python-3.x python-multiprocessing concurrent.futures 2017-12-18

---

0熱

1答えて

遅れているクラインのアプリ

私はクラインとデファーを探しています。次の例では、子プロセスを使用して数値をインクリメントし、Future経由で返すようにしています。私は未来のコールバックを受け取ることができます。 遅延オブジェクトはcb（）関数を呼び出すことはなく、エンドポイントへの要求は返されないという問題があります。問題を特定するのを手伝ってください。続き は、プロセスP1を開始する前にコールバックを追加Process4.

python twisted python-multiprocessing deferred concurrent.futures 2017-12-18

---

0熱

1答えて

asyncioイベントループでconcurrent.futuresを使用できないのはなぜですか？それはasyncio持っていることを述べasyncioドキュメントから

： 「concurrent.futuresモジュールに1を模倣する未来のクラスを、しかし、イベントループでの使用に適合;」 なぜ標準ライブラリに2つの異なるFutureクラス（asyncioとconcurrentで）が必要ですか？なぜイベントループのためにそれを適応させる必要があるのでしょうか？私はここで何が欠けているのでしょうか、それとも彼らがそれをそのように決めるのか？

python future python-asyncio concurrent.futures 2017-09-10

---

1熱

1答えて

ThreadPoolExecutorで作成されたアクティブなスレッドの数を減らしますか？

ThreadPoolExecutorについては、実際に実行されているスレッドの数を監視したいと思います。しかし、これは不可能と思われます。アクティブなスレッドの数は絶えず増加しています。通常のスレッドの場合、ターゲット関数が戻ると、スレッドはシャットダウンします。ときにアクティブ import threading, concurrent.futures def test(): pas

python multithreading concurrent.futures 2017-09-11

---

1熱

2答えて

Python Processpoolexecutor - キューを強制終了しますか？

thats私の最初の質問stackoverflow。私は主にここで私が知る必要があるものを見つけることができました。このbtwのために多くのありがとう。 ただし、私がProcessPoolExecutorをkillしようとすると、生成されたキュー全体を処理するだけです（私はそう思いますか？）。 Processpoolexecutorのキューをすぐにクリーンアップする簡単な方法はありますか？ fro

python concurrent.futures 2017-12-31

---