Paralelleştirelim mi?

R'da Paralel Programlama

Nabeel Imam

Data Scientist

Hadi bir bina inşa edelim

Son katın üstüne yeni kat yapmak: ardışık

Bitmiş yapıya pencere takmak: paralel

Bir bina inşaat halinde. Katlar yalnızca sırayla yapılabilir, pencereler ise paralel takılabilir.

Ardışık–paralel ölçeği

Yaygın hesaplama görevleri bir ölçeğe yerleştirilmiş: bir uçta ardışık, diğer uçta paralel. Yeni değişken oluşturma paralel uca yakınken, kümülatif toplam ardışık uca yakındır.

Klasik bir sayısal işlem

Bir milyon sayının kareköklerini hesaplamak

numbers <- 1:1000000


start <- Sys.time()
sq_roots <- lapply(numbers, sqrt)
end <- Sys.time()


end - start

Time difference of 1.044573 secs

Karekökü nasıl paralelleştiririz?

Karekökleri paralel hesaplamak için bir akış şeması. Birden milyona kadar tam sayılar, her biri 200.000 uzunluğunda beş gruba ayrılır.

Karekökü nasıl paralelleştiririz?

Bölünmüş veriler, birden fazla çekirdekten oluşan kümeye gönderilir. Her sayı grubu, karekök hesabı için bir çekirdeğe gider. Tüm çekirdekler meşgulse, yeni gruplar çekirdek boşalana kadar bekler.

Karekökü nasıl paralelleştiririz?

Karekökler her çekirdekten toplanır ve birleştirilerek bir milyon karekök elde edilir.

Paralelleştirilmiş bir sayısal işlem

Bir milyon sayının karekökleri, paralel olarak

library(parallel)


my_cluster <- makeCluster(3)


start <- Sys.time()
sq_roots <- parLapply(my_cluster, numbers, sqrt)
end <- Sys.time()


stopCluster(my_cluster)


end - start