我正在并行运行大量迭代.某些迭代比其他迭代花费更多(比如说100倍).我想把它们计算出来,但我宁愿不必深入研究函数背后的C代码(称之为fun.c)来做繁重的工作.我希望有一些类似于try()但有一个time.out选项.然后我可以这样做:
for (i in 1:1000) {
try(fun.c(args),time.out=60))->to.return[i]
}
Run Code Online (Sandbox Code Playgroud)
因此,如果fun.c在某个迭代中花费的时间超过60秒,那么经过修改的try()函数就会杀死它并在这些行上返回警告或其他内容.
有人有什么建议吗?提前致谢.
我正在越来越多地使用Rscript,我通常会使用bash脚本.一个小烦恼是,许多这些脚本循环一些system()调用,如果我试图中断它,R基本上没有时间来捕获我的控制-c.相反,它只是中止正在运行的系统命令并继续下一个循环迭代.例如,当我尝试通过按住control-c来中断以下操作时,它仍然会通过所有迭代:
for(i in 1:10) {
cat(i)
system('sleep 3')
}
Run Code Online (Sandbox Code Playgroud)
到目前为止,我总是通过在每个循环中插入一个小暂停来解决这个问题
for(i in 1:10) {
Sys.sleep(0.25)
cat(i)
system('sleep 3')
}
Run Code Online (Sandbox Code Playgroud)
如果我按住control-c,这将让我在一两次迭代中中止,但我想知道,有没有更有效的方法来实现这种行为?
在R控制台中工作时,我想设置监视特定连接的后台任务,当事件发生时,执行另一个功能(警报).或者,我可以进行设置,以便外部函数只是向R发送警报,但这似乎是同样的问题:有必要设置一个监听器.
我可以在R的专用过程中执行此操作,但我不知道在控制台中是否可行.另外,如果它正在计算一个函数,我对中断R不感兴趣,但是如果控制台只是在等待输入,则警告或中断.
以下是三个用例:
最简单的例子是观看文件.假设我有一个名为"latestData.csv"的文件,我想监视它的变化; 当它改变时,myAlert()执行.(可以将它扩展为执行不同的操作,但只是弹出一个文件已更改的注释是有用的.)
一种不同类型的监视器将监视给定的机器是否在RAM上运行不足并且可能执行save.image()并终止.同样,这可能是一个简单的问题,即观察由外部监视器生成的文件,该文件可以保存输出top或其他命令.
一个不同的例子就像另一个最近的SO问题,关于:让R停止正在运行的EC2机器.如果来自另一台机器或进程的警报告诉程序保存并终止,那么能够监听该警报将是很好的.
目前,我怀疑有两种方法可以解决这个问题:通过Rserve和可能的via fork.如果有人有关于如何使用包或通过其他方法执行此操作的示例,那将是很好的.我认为解决这三个用例中的任何一个都可以解决所有这些问题,模拟一些外部代码.
注1:我意识到,根据另一个SO问题的答案,R是单线程的,这就是我怀疑fork和Rserve可能工作的原因.但是,如果一个人与R终端接口,我不确定可行性.虽然R的REPL附加到控制台的输入,但我试图绕过它或模仿它,这是答案的地方fork或Rserve可能.
注2:对于那些熟悉事件处理/事件处理方法的人来说,这也可以解决所有问题.我在R中找不到任何相关内容.
更新1:我发现编写R扩展的手册有一个引用事件处理的部分,其中提到了使用R_PolledEvents.这很有希望.