concurrentを用いた並列処理（センサー・処理出力の並列処理）

Question

前提・実現したいこと

2次元のセンサー入力データを2次元行列に変換し，その行列を入力として処理を行い，すぐに結果を表示させるシステムを実現したいと思っております．現在のプログラムは，「センサー入力データの変換ー＞処理と表示」と逐次なっているため，センサー入力の変換をしている間は，結果表示が止まってしまいます．

なので，「センサー入力・行列変換」と「処理＋結果表示」を並列プロセスで行えるプログラムにしたいと思っております．

ここに質問の内容を詳しく書いてください。
concurrent.futuresを使って並列処理をしようとしているのですが，executor.submitを使うと「np.arrayは使えない」とエラーになり，executor.mapを使ってイテレータで出力すると，結果が[]になってしまいます．

発生している問題・エラーメッセージ

executor.submitの場合
TypeError: 'numpy.ndarray' object is not callable`
executor.map

[] 

### 該当のソースコード

def func(x,y,z):
    ,,,
    return(2d-array)

executor = concurrent.futures.ThreadPoolExecutor(max_workers=2)
    rets = executor.map(func(a, b, c))
    tmp = np.fromiter(rets, int)
    print(tmp)

もしくは，

executor = concurrent.futures.ThreadPoolExecutor(max_workers=2)
    rets = executor.submit(func(a, b, c))
    print(rets.result())

### 試したこと
executor.submit 
result()を試しましたが，np.ndarrayは呼び出せない（以上のエラー）となる．
そこで，executor.mapを試しましたが，[]となって値を渡せません．

Answer 1

まず、Pythonの関数呼び出しの評価順序(計算順序)について理解してください。

>>> def function1(n):
...     print('function1 received parameter n =', n)
...     return n + 2
...
>>> def function2(n):
...     print('function2 received parameter n =', n)
...     return n * 10
...
>>> function1(function2(4))
function2 received parameter n = 4
function1 received parameter n = 40
42

上記のコードではfunction1の引数にfunction2の実行結果を与えています。
その場合、まず、function2(4)が計算されて、その結果をfunction1が受け取ることになります。

rets = executor.submit(func(a, b, c))
を実行するということは、まずfunc(a, b, c)を(親スレッドで)実行して、その結果をworkerで実行してくださいとexecuterに依頼するということです。
ところが、func(a, b, c)の結果はndarrayなので実行できないですよというエラーが出ています。

executer.submitの引数が何であるかはExecutor オブジェクトに書かれていますので、それを読めば解決策は簡単にわかるはずです。