并行化:包“并行”而不是“Parallelization”

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)

基于使用本教程，我编写了以下代码..。

更新:正确的代码提供如下：

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)

这就是错误。