はPMAPでBATCH_SIZE（）ジュリア・ラングでジュリア

Question

を設定し、ドキュメントはあなたがBATCH_SIZEを使用してワーカー・プロセスの数を設定することができます状態：

pmap([::AbstractWorkerPool, ]f, c...; distributed=true, batch_size=1, on_error=nothing, retry_n=0, retry_max_delay=DEFAULT_RETRY_MAX_DELAY, retry_on=DEFAULT_RETRY_ON) → collection 

しかし、私は合格する方法の作業例を見つけることができないようパラメータ。

私は試しました： pmap（f、x; true、10）とpmap（f、x; distributed = true、batch_size = 10）両方のメソッドが動作しませんでした。誰もがbatch_sizeの引数を渡す正しい方法を知っていますか？

Answer 1

バッチサイズはマッピングのリストを分割することを意味します。つまり、リスト1：100があり、バッチサイズ10を選択した場合、ワーカープロセスがマップ関数1から2の代わりにfx [1,2,3,4,5,6,7,8,9,10]が必要です。マッピングしている関数がシンプルなので、これは簡単です。スケジューラ（プロセス1）がスケジュールするために

とにかく...名前付き引数の使い方...あなたは私の疑惑をセミコロンで確認した、私は人々が入力する必要があると思うかもしれないと思った。あなたはそれを入力するつもりはありません、セミコロンがあるので、名前付き引数は何かを知っています

ie folliwing方法に

function foo(x) 
    myid() 
end 

と

pmap(foo, 1:100, batch_size = 1) 

と

pmap(foo, 1:100, batch_size = 10)