將全局和函數環境中的對象導出到集羣

我在下面的示例代碼中使用了foreach和doParallel。將全局和函數環境中的對象導出到集羣

library(foreach) 
    library(doParallel) 
    clusters = makeCluster(4) 
    registerDoParallel(clusters) 


    fun1 <- function(param1, param2, param3) 
    { 
    param4 = param1+param2 
    param5 = param2+param3 
    param6 = param3+param1 
    print(ls(envir = environment())) 
    print(ls(envir = .GlobalEnv)) 
    # clusterExport(cl = clusters, varlist = ls(), envir = environment()) 
    clusterExport(cl = clusters, varlist = ls(), envir = .GlobalEnv) 
    mmm = foreach(i = 1:length(param1), .combine = rbind) %dopar% fun2(i, param4, param5, param6) 
    print(mmm) 
    } 

    fun2 <- function(i, param4, param5, param6) 
    { 
    j = param4[i] * param5[i] * param6[i] 
    } 

    param1 = 1:10 
    param2 = 2:11 
    param3 = 3:12 
    fun1(param1, param2, param3)

在clusterExport的ENVIR說法，當我使用ENVIR = .GlobalEnv，我得到的錯誤

**"Error in get(name, envir = envir) : object 'param4' not found"**。

當我使用ENVIR =環境（），錯誤是

**"Error in fun2(i, param4, param5, param6) : task 1 failed - "could not find function "fun2"""**

我的問題是如何能在全球所有對象以及功能環境導出到一個集羣。

來源

2016-12-28 Sim101011

您有一個帳戶在堆棧溢出。你爲什麼不在這裏發佈這個問題？這裏的話題是無關緊要的。 – Roland

library(doParallel) 
clusters = makeCluster(4) 
registerDoParallel(clusters) 


fun1 <- function(param1, param2, param3) 
{ 
    param4 = param1+param2 
    param5 = param2+param3 
    param6 = param3+param1 

    mmm = foreach(i = 1:length(param1), .combine = rbind, .export = "fun2") %dopar% fun2(i, param4, param5, param6) 
    mmm 
} 

fun2 <- function(i, param4, param5, param6) 
{ 
    param4[i] * param5[i] * param6[i] 
} 

param1 = 1:10 
param2 = 2:11 
param3 = 3:12 
fun1(param1, param2, param3) 
#   [,1] 
#result.1  60 
#result.2 210 
#result.3 504 
#result.4 990 
#result.5 1716 
#result.6 2730 
#result.7 4080 
#result.8 5814 
#result.9 7980 
#result.10 10626

來源

2016-12-28 08:49:28 Roland

將全局和函數環境中的對象導出到集羣

回答

相關問題