установка 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; distribution = true, batch_size = 10) abut оба метода не работают. Кто-нибудь знает правильный способ передать аргумент для batch_size?

Answer 1

Размер партии предназначен для разбивки списка вашего отображения, что означает, что если у вас есть список 1: 100, и вы выбираете размер партии 10, каждый рабочий процесс «обходит» с помощью функции карты он принимает fx [1,2,3,4,5,6,7,8,9,10] вместо 1 или 2, это preffereble, если функция, которую вы просматриваете, прост, поэтому она упрощает для планировщика (процесс 1) запланировать

в любом случае ... на использование именованных аргументов ... вы подтвердили мое подозрение на точку с запятой, я задался вопросом, могут ли люди подумать, что они должны ввести его. . Вы должны ввести его, точка с запятой, чтобы вы знали, что названо аргументами

ie do нт точки с запятой

pmap(f, c..., batch_size=10) 

лучше, что я имею в виду попытаться создать метод folliwing

function foo(x) 
    myid() 
end 

и тест призывающей

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

и

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