중첩 된 for 루프를 병렬 처리하십시오.

Question

아래 코드를 R로 병렬 처리하고 싶습니다. for 중첩 된 for 루프입니다. 사용 할 수있다 (

Error in { : task 1 failed - "invalid 'type' (list) of argument"

이 코드를 병렬화하는 더 좋은 방법이 있나요 :

for (i in 1:nrow(my_dataset_preprocessed)){ 
    for (j in 1:ncol(my_dataset_preprocessed)){ 
     my_dataset_preprocessed[i,j] = min(my_dataset_preprocessed[i,j], 0.1) 
    } 
} 

나는

library(foreach) 
library(doParallel) 
registerDoParallel(detectCores()) 
clusterExport(cl, "my_dataset") 

threshold_par <- function (X) { 
    co <- foreach(i=1:nrow(X)) %:% 
       foreach (j=1:ncol(X)) %dopar% { 
        co = min(X[i,j], 0.1) 
       } 
    matrix(unlist(co), ncol=ncol(X)) 
} 

system.time(threshold_par(my_dataset)) 

doParallel

사용하여 아래의 코드를 시도하고있다 그러나 나는 다음과 같은 오류를 얻고있다 parLapply)? 그렇지 않은 경우 위 코드를 어떻게 수정합니까?

Answer 1

cl을 신고하지 않았습니다. 당신이 clusterExport(cl, "my_dataset")

library(foreach) 
library(doParallel)  
registerDoParallel(detectCores()) 
getDoParWorkers() 
# [1] 8 

threshold_par <- function (X) { 
    co <- foreach(i=1:nrow(X)) %:% 
       foreach (j=1:ncol(X)) %dopar% { 
        co = min(X[i,j], 0.1) 
       } 
    matrix(unlist(co), ncol=ncol(X)) 
} 

test <- matrix(1:4, ncol=2) 
system.time(threshold_par(test)) 
#  user system elapsed 
#  0.01 0.00 0.02