为何callr无法找到myFunction函数？技术问题咨询

为什么callr子进程找不到myFunction？ #

callr启动的子R进程是完全独立的运行环境，不会自动继承父进程全局环境中的函数、变量。你第一次调用时，匿名函数里的myFunction只存在于父进程的全局环境，子进程中没有这个函数定义，因此报错。

第二种写法的错误更直接：callr::r()的第一个参数要求是函数对象，但你传入的是myFunction(dataPath, fileId)——这已经是函数执行后的结果（字符串），不是函数本身，所以触发类型检查错误。

正确的调用方式 #

方式1：在子进程函数内部定义myFunction #

把函数定义包含在传给callr的匿名函数中，确保子进程能访问到：

myFunction <- function(dataPath, fileId) {
  Sys.sleep(10)
  paste0(dataPath, fileId)
}

dataPath <- "./"
fileId <- "file01"

# 正确调用
filePath <- callr::r(function(dataPath, fileId) {
  # 子进程内重新定义函数
  myFunction <- function(dataPath, fileId) {
    Sys.sleep(10)
    paste0(dataPath, fileId)
  }
  myFunction(dataPath, fileId)
}, args = list(dataPath, fileId))

方式2：用export参数导出父环境的函数 #

通过export参数指定要传递给子进程的对象，避免重复定义：

myFunction <- function(dataPath, fileId) {
  Sys.sleep(10)
  paste0(dataPath, fileId)
}

dataPath <- "./"
fileId <- "file01"

filePath <- callr::r(function(dataPath, fileId) myFunction(dataPath, fileId), 
                     args = list(dataPath, fileId),
                     export = "myFunction") # 导出父环境的myFunction到子进程

方式3：把函数作为参数传递 #

直接将myFunction作为参数传入子进程的函数：

myFunction <- function(dataPath, fileId) {
  Sys.sleep(10)
  paste0(dataPath, fileId)
}

dataPath <- "./"
fileId <- "file01"

filePath <- callr::r(function(dataPath, fileId, func) func(dataPath, fileId), 
                     args = list(dataPath, fileId, myFunction))

适配你的异步多核需求 #

要同时运行2-3个异步任务，使用callr::r_bg()启动后台子进程，避免阻塞主进程：

myFunction <- function(dataPath, fileId) {
  # 替换为实际的JSON处理逻辑，比如jsonlite::read_json(paste0(dataPath, fileId))
  Sys.sleep(10)
  paste0(dataPath, fileId)
}

# 启动多个异步任务
task1 <- callr::r_bg(function(dataPath, fileId) myFunction(dataPath, fileId),
                     args = list("./", "file01"),
                     export = "myFunction")

task2 <- callr::r_bg(function(dataPath, fileId) myFunction(dataPath, fileId),
                     args = list("./", "file02"),
                     export = "myFunction")

# 检查任务状态
task1$is_alive()
task2$is_alive()

# 等待任务完成并获取结果
result1 <- task1$wait()
result2 <- task2$wait()

内容的提问来源于stack exchange，提问作者Robert Hadow