Pythonのconcurrent.futureモジュールの戻り値について

Question

forループを用いた関数の引数にpandas.DateFrame入れた関数で、concurrent.futuresクラスのProcessPoolExecutorやThreadPoolExecutorを用いて並列処理を試みました。
jupyter notebook上で実行しましたが、どちらも.result()で結果を呼び出すと、
TypeError: 'DataFrame' object is not callable
となってしまい、DataFrameを呼んでくれません。

関数のコード自体が上手くない、間違っていると言う可能性はありますが、そもそも、ProcessPoolExecutorやThreadPoolExecutorの使い方として、pandas.DateFrameを引数や戻り値にしたりすることは出来ないのでしょうか。

def func(df):
   for i in range(len(df)):
       処理

以下の引数sampleがpandas.DateFrameです。

from concurrent.futures import ProcessPoolExecutor, Future

with ProcessPoolExecutor(max_workers=4) as pool:
    future = pool.submit(func(sample))

future.result()

Answer 1

全体詳細が不明なので、submit関数への引数の渡し方だけについての言及になりますが、

    future = pool.submit(func, sample)

としてみてはどうでしょうか。

参照：Executor オブジェクト

Comments

[fu_3823]

上手くいきました。引数の扱いについて思い込みで書いていました。どうもありがとうございました。