0

嗨，我想使用 doSNOW/foreach 包创建一个命名列表。例如，最终产品将是一个列表对象。从向量命名的 dfe 说，

n=c("n1","n2","n3","n4","n5")

这样我就可以访问列表对象的列表，例如dfe[["n1"]]$aa 是列表中的元素。

这是我正在谈论的一个例子。

mainStart <- Sys.time()

n=c("n1","n2","n3","n4","n5")

cores=detectCores() 
cl <- parallel::makeCluster(cores[1]-1) #not to overload your computer
registerDoSNOW(cl)

## setup progress bar 
pb <- txtProgressBar(max = 5, style = 3)
progress <- function(n) setTxtProgressBar(pb, n)
opts <- list(progress = progress)


dfe <-  foreach(id.this = n, .combine = list, .options.snow = opts) %dopar% {
    list ( a=c(1,2,3), b = c(1,2,3))
}

endTime <- Sys.time()
endTime -mainStart 


close(pb)
stopCluster(cl)

因此，如果我在 foreach 循环中创建的列表可以是循环后的名称和访问权限，那就太好了。这样 dfe[["n1"]]$a 可以给我向量 1,2,3。

4

1 回答 1

0

正如上面所建议的那样，只设置名称（dfe，n）更容易，但是我认为这不会起作用，因为某些过程可能需要比其他过程更长的时间，但似乎顺序没有改变。例如，当我设置

if ( id.this == "n2"){
        Sys.sleep(10)
    }

订单仍然保留。所以最终的代码会是这样的。

mainStart <- Sys.time()

n=c("n1","n2","n3","n4","n5")

cores=detectCores() 
cl <- parallel::makeCluster(cores[1]-1) #not to overload your computer
registerDoSNOW(cl)

## setup progress bar 
pb <- txtProgressBar(max = 4, style = 3)
progress <- function(n) setTxtProgressBar(pb, n)
opts <- list(progress = progress)


dfe <-  foreach(id.this = n, .options.snow = opts) %dopar% {
    #list(id.this = list(  a=c(1,2,3), b = c(1,2,3) ) )
    if ( id.this == "n2"){
        Sys.sleep(10)
    }
    list(  a=c(id.this,2,3), b = c(1,2,3) )
}

endTime <- Sys.time()
endTime -mainStart 


close(pb)
stopCluster(cl)

dfe=setNames(dfe, n)
于 2018-07-25T17:25:33.880 回答