Экспортировать объекты в глобальную и функциональную среду в кластер

Question

Я использую 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) 

В ENVIR аргумента clusterExport, в когда я использую 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"""**

Мой вопрос, как я могу экспортировать все объекты в глобальном, а также функции среды в кластере.

Answer 1

Когда вы находитесь в функции, вам не нужно вручную экспортировать нужные вам объекты. Но вы должны пройти fun2 до fun1, если вы хотите, чтобы к нему обращались foreach в fun1. Итак, просто выполните:

fun1 <- function(param1, param2, param3, fun2) 
{ 
    param4 = param1+param2 
    param5 = param2+param3 
    param6 = param3+param1 
    mmm = foreach(i = 1:length(param1), .combine = rbind) %dopar% { 
    fun2(i, param4, param5, param6) 
    } 
    print(mmm) 
} 

fun1(param1, param2, param3, fun2)