Использование parLapply и clusterExport внутри функции

Я задал связанный вопрос здесь, и ответ сработал хорошо:с помощью parLapply от parallel :невозможно получить доступ к переменным в параллельном коде

Проблема в том, что когда я пытаюсь использовать ответ внутри функции, он не будет работать, как я думаю, в среде по умолчанию clusterExport. Я прочитал виньетку и посмотрел файл справки, но подхожу к этому с очень ограниченной базой знаний. То, как я использовал parLapply, я ожидал, что оно будет вести себя аналогично lapply, но это не так.

Вот моя попытка:

par.test <- function(text.var, gc.rate=10){ 
    ntv <- length(text.var)
    require(parallel)
    pos <-  function(i) {
        paste(sapply(strsplit(tolower(i), " "), nchar), collapse=" | ")
    }
    cl <- makeCluster(mc <- getOption("cl.cores", 4))
    clusterExport(cl=cl, varlist=c("text.var", "ntv", "gc.rate", "pos"))
    parLapply(cl, seq_len(ntv), function(i) {
            x <- pos(text.var[i])
            if (i%%gc.rate==0) gc()
            return(x)
        }
    )
}

par.test(rep("I like cake and ice cream so much!", 20))

#gives this error message
> par.test(rep("I like cake and ice cream so much!", 20))
Error in get(name, envir = envir) : object 'text.var' not found

34
задан Community 23 May 2017 в 12:10
поделиться