Code parallèle pour calculs multiples asynchrones dans Julia

Question

Je sais que cela aurait pu être demandé dans le passé, mais je suis un débutant absolu dans Julia.

J'ai un code simple dans Julia que je voudrais exécuter en parallèle.

#--Two Calculations during the Loop-- 

vt_0=0 
ct_0=0 

for i=1:10 

#--Calculation vt_1 
vt_1=max(rand(1:i),vt_0,ct_0) 


#--Calculation ct_1 
ct_1=min(rand(1:i),vt_0,ct_0) 

ct_0=ct_1 
vt_0=vt_1 

end 

Comme vous pouvez le voir, le calcul des vt_1 et ct_1 pourrait se faire en même temps (ou au cours de la même boucle sans avoir le calcul ct_1 en attente pour le calcul vt_1).

Quelqu'un peut-il m'aider à modifier ce code pour fonctionner en parallèle? Devrais-je télécharger un script/une bibliothèque de Julia? (J'ai un beaucoup plus grand et le code compliqué pour programmation dynamique, mais l'essence est la même.)

Nous vous remercions à l'avance

Answer 1

Est-ce ce que vous cherchez? Probablement plus rapide de ne pas utiliser la fonction anonyme comme je l'ai ici mais à part ça.

addprocs(2)   
vt_0 = 0; ct_0 = 0; 
for i=1:10 
    #--Calculation vt_1 
    vt_1 = remotecall((x,y)->max(rand(1:i),x,y), 2, vt_0, ct_0) 

    #--Calculation ct_1 
    ct_1 = remotecall((x,y)->min(rand(1:i),x,y), 3, vt_0, ct_0) 

    ct_0 = fetch(ct_1) 
    vt_0 = fetch(vt_1) 
end 

ou sans funcs anonymes:

addprocs(2) 
@everywhere minrand(i,x,y) = min(rand(1:i),x,y) 
@everywhere maxrand(i,x,y) = max(rand(1:i),x,y) 
vt_0 = 0; ct_0 = 0; 

for i=1:10 
    #--Calculation vt_1 
    vt_1 = remotecall(maxrand, 2, i, vt_0, ct_0) 

    #--Calculation ct_1 
    ct_1 = remotecall(minrand, 3, i, vt_0, ct_0) 

    ct_0 = fetch(ct_1) 
    vt_0 = fetch(vt_1) 
end 

Answer 2

Je serai curieux de savoir s'il y a une réelle bonne réponse à cette question. L'exécution normalement parallèle dans Julia fait partie de Base, donc vous n'avez besoin d'aucune bibliothèque spéciale pour cela. Mais votre cas d'utilisation n'est pas typique pour l'exécution parallèle IIUC. Normalement, un parallèle pour une boucle itérerait sur l'appel de la même expression avec des valeurs différentes - c'est-à-dire que vous exécuteriez l'expression associée à i = 1 sur un cœur, i = 2 sur un autre et fusionner les résultats. Il y a une bonne explication ici: https://docs.julialang.org/en/latest/manual/parallel-computing/#Parallel-Map-and-Loops-1

Ce que vous suggérez est d'exécuter différents morceaux du programme (expressions différentes) sur différents cœurs. EDIT: Il y a une bonne description de la façon de le faire dans la réponse d'Alexander.