使用future.callr调用含sink的R函数时仅输出首行，如何修复？

问题原因 #

当使用plan(callr)时，future会启动独立的R进程执行任务。原脚本中sink的作用域与子进程的输出捕获机制冲突，导致第二次print的输出被callr的输出捕获逻辑拦截，无法写入文件。

修复方案 #

方案1：在函数内完整控制sink生命周期 #

将sink的开启和关闭完全封装在任务逻辑内，同时强制刷新输出流确保内容写入：

library(future.callr)
plan(callr)

executeInternalActivity <- function() {
  # 开启sink，设置追加模式并保留控制台输出
  sink("output.txt", append = TRUE, split = TRUE)
  on.exit(sink()) # 确保函数结束时必关sink
  
  print(Sys.time())
  flush.console() # 强制刷新缓冲区到文件
  print(Sys.time())
  flush.console()
}

# 用future调用任务
f <- future(executeInternalActivity())
value(f)

方案2：直接写入文件绕过sink #

不依赖sink，直接通过文件连接写入内容，避免与callr的输出捕获机制冲突：

library(future.callr)
plan(callr)

executeInternalActivity <- function() {
  con <- file("output.txt", open = "a")
  on.exit(close(con)) # 确保文件连接必关闭
  
  cat(Sys.time(), "\n", file = con)
  cat(Sys.time(), "\n", file = con)
}

# 用future调用任务
f <- future(executeInternalActivity())
value(f)

关键说明 #

• on.exit(sink())或on.exit(close(con))：避免函数出错时文件连接未关闭导致的资源泄漏。
• append = TRUE（或open = "a"）：防止每次调用覆盖原有文件内容，若需生成新文件可改为open = "w"。
• flush.console()：强制将内存缓冲区内容写入文件，避免子进程结束前输出滞留。

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