распараллеливания: пакет «параллельно» вместо «mclapply»

Question

Я пытаюсь преобразовать этот код на тот, который может быть выполнен на Windows:

numCores <- detectCores() 
results <- mclapply(seq(1, 500), function(file, fID){ 
    myData <- fread(file.path(dirPath, fID, paste0(file, ".csv"))) 
    return(cbind(myData, rep(file, nrow(myData)))) 
}, mc.cores = numCores, fID = 1) 

на основе использования this tutorial, я написал следующий код .. .

UPDATE: правильный код приведен ниже:

getAllMyData <- function(numCores,folderID) 
{ 
    dirPath = paste0("D:/home/", folderID, '/') 
    cl <- makeCluster(4) 
    allTrips = parLapply(cl, 1:200, function(z){ 
    myData <- read.csv(paste0(dirPath, z, ".csv")) 
    return(cbind(myData , rep(z, nrow(myData)))) 
    }) 
    stopCluster(cl) 
    return(allTrips) 
} 

numCores <- detectCores() 
allMyData <- getAllMyData(numCores,1) 

Answer 1

Ваш первый код вызывает функцию

function(file, fID) 

Ваш второй код, напротив, использует

function(dirPath,fID) 

Это ошибка.