ThreadPoolExecutorコールバック？

Question

私は次のコードを持っている：実際のダウンロードタスクが非同期的に継続しながら、

from concurrent.futures import ThreadPoolExecutor 

def download_contract_history(self, **kw): 
    ThreadPoolExecutor().map(lambda x: x.download_contract_history(**kw), self.instruments.values()) 
    print("All downloads complete.") 

を現時点では、すぐに「すべてのダウンロードが完了し、」印刷します。スレッドが実際に終了した後、ステートメントを印刷するにはどうすればよいですか？ https://docs.python.org/dev/library/concurrent.futures.html#concurrent.futures.ThreadPoolExecutorで

Answer 1

理由：マップする

等価（FUNC、*イテラブル）FUNC以外は非同期に実行され、FUNCにいくつかの呼び出しを同時に行うことができます。

あなたが現在に滞在し気にしない場合：あなたは確かにprint文に続行されませんので

from multiprocessing.pool import ThreadPool as Pool 
Pool(processes=4).map(lambda x: x.download_contract_history(**kw),self.instruments.values()) 

プールマップ機能は、ブロッキング機能です。

あなたはおそらくそう定期的にマルチを使用するには、（私が思うに、私は間違って誰だなら、私を修正）このような何かのためのスレッド（GILをスレッドのGoogleのpython）を使用する必要はありません注：

from multiprocessing import Pool 

Answer 2

他のことを同時に行うことができることは、一種のポイントです。完了するのを待つ場合は、返された結果を確認する必要があります。

The docsは非常に明確ではないが、彼らは言う： __next__()が呼び出されたconcurrent.futures.TimeoutError場合

は

返されるイテレータは上昇し、その結果は、タイムアウト秒

だから、後に使用できません。 mapは結果イテレータを返し、その結果は未来のものではないため、実際の結果であるようです。

from concurrent.futures import ThreadPoolExecutor 

def download_contract_history(self, **kw): 
    results = list(
     ThreadPoolExecutor().map(
      lambda x: x.download_contract_history(**kw), 
      self.instruments.values() 
     ) 
    ) 
    print("All downloads complete.")