Tôi có thể lồng song song ::: parLapply() không?

Question

Giả sử rằng tôi muốn làm một cái gì đó trong R mà bình thường (trong một quá trình/thread) trông như thế này:

for(i in 1:2) { 
    for(j in 1:2) { 
     #Do some stuff here 
    } 
} 

Sử dụng song song gói mới R, trên một máy lõi tứ, tôi có thể làm như sau?

cluster<-makeCluster(4) 

innerLoop<-function() { 
    #Do some stuff here 
} 

outerLoop<-function() { 
    result<-do.call(, parLapply(cluster, c(1:2), innerLoop)) 
} 

final.result<-do.call(, parLapply(cluster, c(1:2), outerLoop)) 

Điều này có thể thực hiện với gói song song đi kèm với R-2.14.0 không?

Answer 1

Có, bạn có thể làm điều đó. Đối với mức độ song song đầu tiên, bạn phải sử dụng công nghệ bộ nhớ phân tán (như makeCluster() từ gói tuyết) và ở mức thứ hai của sự song song bạn phải sử dụng công nghệ bộ nhớ chia sẻ (gói đa lõi, mclapply()).

Dưới đây là một ví dụ mã đơn giản:

library(parallel) 

cl <- makeCluster(2) 

inner <- function(x){ 
    pid <- Sys.getpid() 
    name <- Sys.info()["nodename"] 
    str <- paste("This is R running on", name, "with PID", pid, "!") 
    return(str) 
} 

outer <- function(x, cores, funceval){ 
    require(parallel) 
    mclapply(1:cores, funceval) 
} 

parLapply(cl, 1:length(cl), outer, 2, inner) 

Trong đầu ra bạn sẽ thấy tên máy khác nhau và PID khác nhau!