卸载rJava和/或重启JVM

Question

我想将rJava与mcparallel结合使用，但显然JVM不能分叉。因此，需要为每个子进程启动一个单独的JVM实例，例如:

library(rJava)
library(parallel)
myfile <-  system.file("tests", "test_import.xlsx", package = "xlsx")
#This works:
mccollect(mcparallel({
  #Automatically initiates JVM in child
  xlsx::read.xlsx(myfile, 1)
}))

然而，在我的情况下，问题是JVM已经在(主)父进程中启动了。这使得无法在子进程中使用rJava:

#init JVM in parent
.jinit()
#Doesn't work anymore
mccollect(mcparallel({
  xlsx::read.xlsx(myfile, 1)
}))

所以我真正需要的是一种在子进程中关闭/杀死和重新启动JVM的方法。简单地说，detach("package:rJava", unload = TRUE)似乎并不奏效。force.init参数似乎也不会导致重启:

#Also doesn't work:
.jinit()
mccollect(mcparallel({
  .jinit(force.init = TRUE)
  xlsx::read.xlsx(myfile, 1)
}))

是否有某种方法可以强制关闭/杀死JVM以便在子进程中重新启动它?

Answer 1

有一种方法可以使用rJava并行运行表达式，基于运行并行进程来获取和组装所有结果在主进程中加载rJava库。由于主R进程没有启动jvm，那么java将在每个子进程中启动，并且这个特定的实例也将与子进程一起死亡。

# Rsession started
library(parallel)
myfile <-  system.file("tests", "test_import.xlsx", package = "xlsx")
e <- expression({
require(rJava)
require(xlsx)
read.xlsx(myfile, 1)
})
p <- mcparallel(e)
q <- mcparallel(e)
pq <- mccollect(list(p, q))
# again to check reproducibility
p <- mcparallel(e)
q <- mcparallel(e)
pq2 <- mccollect(list(p, q))
identical(unname(pq),unname(pq2))
# see the result if it is the right content and not tryerr
pq
# now the main continues ...
# and if necessary even load rJava