具有自己创建的函数的doParallel
doParallel是一个R语言中的包，它提供了一种简单且高效的方法来实现并行计算。它基于foreach包，可以在多核或多节点的计算机上并行执行循环操作。
doParallel的主要特点和优势包括：
- 并行计算：doParallel允许将循环操作分解为多个任务，并在多个处理器或计算节点上同时执行，从而加快计算速度。
- 简单易用：使用doParallel非常简单，只需几行代码就可以将循环操作转换为并行计算。它提供了一组直观的函数来管理并行计算的设置和控制。
- 跨平台支持：doParallel可以在各种操作系统上运行，包括Windows、Mac和Linux等。
- 可扩展性：doParallel可以轻松地扩展到大规模计算集群，通过连接多个计算节点来实现更高的计算能力。
doParallel适用于各种应用场景，特别是在需要处理大规模数据集或进行复杂计算的情况下。它可以用于数据分析、机器学习、统计建模、模拟实验等领域。
腾讯云提供了一系列与并行计算相关的产品和服务，可以与doParallel结合使用，以实现更高效的云计算。其中包括：
- 弹性MapReduce（EMR）：腾讯云EMR是一种大数据处理平台，可以提供分布式计算和存储能力，支持并行计算任务。
- 弹性容器实例（Elastic Container Instance，ECI）：腾讯云ECI是一种无需管理基础设施的容器服务，可以快速部署和运行容器化应用程序，提供高度可扩展的计算资源。
- 弹性伸缩（Auto Scaling）：腾讯云Auto Scaling可以根据实际需求自动调整计算资源的规模，以满足并行计算任务的需求。
更多关于腾讯云的产品和服务信息，请参考腾讯云官方网站：https://cloud.tencent.com/
相关·内容
2回答
如果我在没有注册集群的情况下运行foreach... %dopar%，foreach会抛出一个警告，并按顺序执行代码：
library("doParallel")
foreach(i=1:3) %dopar%
sqrt(i)
收益率：
Warning message:
executing %dopar% sequentially: no parallel backend registered
但是，如果我在启动、注册和停止集群后运行相同的代码，它将失败：
cl <- makeCluster(2)
registerDoParallel(cl)
stopCluster(
浏览 0提问于2014-08-03得票数 36
回答已采纳
摘要
我正在开发一个使用Rcpp的R包。我带着许多问题接手了这个项目，我正在努力解决它们。这方面的问题是，我不知道如何在这种情况下创建一个最小的复制示例，因为包相当大，而且我没有参与早期的设置。我很想知道如何解决这个问题，我是刚开始用R/Rcpp编写软件包的。
我让它进入了一种状态，它通过了在macOS和Linux上的自动R检查。
有一个名为“R/simate.R”的不推荐文件，其中包含一个不再使用的函数。我正在尝试删除这个文件。
有关项目如下：
...
#' @useDynLib myPackage
#' @export
#' @import CompQuadForm
浏览 10提问于2022-01-24得票数 -1
回答已采纳
1回答
我使用options()和getOption()来设置代码执行方式的选项。在顺序操作中，它工作得很好。 但是，当我使用doparallel包并行运行我的代码时，这些选项不会传递给工作进程。显示问题的示例代码： library(doParallel)
library(foreach)
registerDoParallel()
options(a=1)
getOption('a')
## [1] 1
foreach(id=1) %dopar% getOption('a')
## [[1]]
## NULL 正如您所看到的，选项向量不会传递给并行工作线程。我尝
浏览 23提问于2019-02-22得票数 0
1回答
我有这样的代码来并行地编写我的结果。我在R中使用foreach和doParallel库。
output_location='/home/Desktop/pp/'
library(foreach)
library(doParallel)
library(data.table)
no_cores <- detectCores()
registerDoParallel(makeCluster(no_cores))
a=Sys.time()
foreach(i=1:100,.packages = c('f
浏览 1提问于2018-06-21得票数 5
回答已采纳
使用类型= MPI的"doParallel“包与直接使用doMPI有什么区别？
library(foreach)
library(doParallel)
cl <- makeCluster(mpi.universe.size(), type='MPI')
registerDoParallel(cl)
system.time(foreach(i = 1:3) %dopar% {Sys.sleep(i); i})
VS
library(doMPI)
cl <- startMPIcluster(count=2)
registerDoMPI(cl)
system.t
浏览 2提问于2018-05-10得票数 2
回答已采纳
我正在尝试编写一个具有多线程功能的CRAN包。我用doSNOW实现了一个完美的解决方案，但是这个包已经被CRAN团队标记为“替代”了，他们让我切换到doParallel解决方案。这很好，但是我无法找到一种方法来监视使用doParallel完成的作业数量，就像使用doSNOW时一样。以下是我的doSNOW解决方案：
# Set up parameters
nthreads<-2
nreps<-100
funrep<-function(i){
Sys.sleep(0.1)
res<-c(log2(i),log10(i))
return(res)
}
浏览 5提问于2019-10-20得票数 7
回答已采纳
我很好奇，当全局值在doParallel:::doParallelSNOW()中显式指定时，.export的设计参数可能是什么？例如,
library("doParallel")
registerDoParallel(cl <- parallel::makeCluster(2L))
a <- 1
y <- foreach(i = 1L, .export = "a") %dopar% { 2 * a }
## Warning in e$fun(obj, substitute(ex), parent.frame(), e$data) :
##
浏览 0提问于2018-01-13得票数 3
我试图让我的代码在R上并行运行，方法是使用doParallel包和foreach包。我还使用sf包来操作shp文件。我确保我的所有代码都能在foreach循环中工作，只需使用%do%，所以如果有错误，我可以更好地跟踪它。我的代码在使用foreach和% do %时运行得很好，但是当我更改它时，do %dopar% R会继续给我以下错误：
错误在{：任务1失败-“找不到函数”“st_geometry_type”
尽管我在R脚本的顶部清楚地使用了require(sf)。我创建了一个小函数，它只打印出“检查”语句是否为真，以复制错误。
require(sf)
require(doParallel)
浏览 1提问于2019-10-17得票数 1
回答已采纳
我使用发布的示例代码来显示progress_bar (来自progress包)和doParallel + foreach。然而，那里的解决方案使用的是doSNOW (例如我用来测试的杜威布鲁克的代码)，它比doParallel更过时，在构建带有CRAN标志的包时会返回此说明：
使用取代的包：‘doSNOW (>= 1.0.19)’
改变这一点似乎不像预期的那样简单。如果只有registerDoSNOW被registerDoParallel替换，.options.snow被.options.doparallel替换，代码就会运行，但在第二种情况下，根本不会显示任何进度条。
我认为这
浏览 6提问于2021-03-12得票数 3
1回答
我需要将一个复杂的foreach循环转换为一个parLapply函数。
为简单起见，我将使用以下foreach循环：
library(foreach)
library(doParallel)
number_of_cores <- 8
clusters <- 8
doParallel::registerDoParallel(clusters)
m <- foreach(i=1:1000) %dopar% {matrix(rnorm(500*500), ncol=50000); NULL}
浏览 10提问于2021-02-19得票数 1
回答已采纳
最近，我开始使用foreach和doParallel包将代码切换到并行执行。由于不同的线程相互干扰，使用futile.logger日志记录的工作效率很低。因此，我开始使用ParallelLogger，即使在并行设置中，它也应该处理日志记录。不幸的是，我对这个记录器有两个问题，我自己解决不了，也许我做错了什么，或者系统中有一个错误。
第一个问题是，尽管我创建了一个控制台附录(请参阅下面的MWE )，但没有线程登录到控制台上。
我的记录器生成的日志文件损坏的方式是launchLogViewer抛出一个line 40 did not have 6 elements错误。
这是MWE：
浏览 2提问于2018-09-17得票数 1
1回答
关于foreach函数，doParallel和R中的doMC有什么不同？doParallel支持windows，类unix，而doMC只支持类unix。换句话说，为什么doParallel不能直接取代doMC呢？谢谢。
更新：doParallel构建在parallel之上，它本质上是multicore和snow的合并，并自动为您的系统使用适当的工具。因此，我们可以使用doParallel来支持多系统。换句话说，我们可以使用doParallel来取代doMC。
参考：
顺便说一句，registerDoParallel(ncores=3)和
cl <- makeCluster(3)
regi
浏览 5提问于2015-03-11得票数 51
回答已采纳
" foreach“包本质上具有foreach函数。此功能是否仅在此包中可用？并行包是否包含foreach函数？那doParallel包呢？谢谢
浏览 0提问于2018-05-10得票数 0
我试图通过在多个核上并行化来使用%dopar%来加速我的for循环。但是，我无法存储返回的值。下面是一个可重复的小例子。
使用%dopar%
cl <- parallel::makeForkCluster(4)
doParallel::registerDoParallel(cl)
junk_parallel = seq(0,100000,1)
system.time(foreach(i=seq(0,10000,1))%dopar%{
junk_parallel[i] = sqrt(i)})
stopCluster(cl)
输出：
user system elapsed
2.5
浏览 0提问于2019-08-21得票数 2
回答已采纳
在windows平台上，似乎高迭代器的值会停止foreach的运行。例如
library(doParallel)
library(foreach)
cl<-makeCluster(7)
registerDoParallel(cl)
bayes_results<-foreach (n=1:100) %dopar% {n}
这在几秒钟内就能正常工作。
但是，将该值增加到几百万会使foreach停止工作，即使在等待了几个小时之后也是如此。
bayes_results<-foreach (n=1:5000000) %dopar% {n}
有什么问题吗？怎么解决呢？
谢谢。
浏览 0提问于2014-12-25得票数 2
如何向foreach注册PSOCK集群(使用Parallel包创建)？我目前正在使用doSNOW包中的registerDoSNOW来注册snow套接字集群。
浏览 2提问于2011-11-30得票数 7
回答已采纳
我不知道如何解决这个问题。我尝试过像这里一样添加.packages="foreach"，但无法工作。任何帮助都是非常感谢的！
####################
install.packages("doParallel")
install.packages("doSNOW")
install.packages("doParallel")
install.packages("doMPI")
install.packages("tidyverse")
# Load packages -----
浏览 3提问于2020-05-17得票数 0
回答已采纳
我想使用llply来使用多核doParallel后端(即doParallel::registerDoParallel(cores=8))执行一些并行计算，但是每次计算将花费不同的时间，因此我希望将多核预存选择设置为false。但是，我不确定如何将此选项传递给llply，后者将它传递给foreach，后者将把它传递给doParallel，后者将最终将其传递给mclapply。有人能举出这样做的例子吗？
换句话说，我将如何在下面的代码中禁用预编码？
library(plyr)
library(doParallel)
registerDoParallel(cores=2)
x <- llply
浏览 3提问于2014-03-24得票数 3
回答已采纳
我对前额有个问题，我就是搞不懂。以下代码在我尝试过的两台Windows计算机上失败，但在三台Linux计算机上成功，它们都运行着相同版本的R和doParallel：
library("doParallel")
registerDoParallel(cl=2,cores=2)
f <- function(){return(10)}
g <- function(){
r = foreach(x = 1:4) %dopar% {
return(x + f())
}
return(r)
}
g()
在这两台Windows计算机上，返
浏览 7提问于2016-01-07得票数 18
回答已采纳
1回答
我从这个中了解到，在窗口上使用Rcpp函数与doParallel一起使用的最简单方法是构建一个包。我目前正在构建一个R包，我需要并行处理包中的一些任务。我有一个Rcpp函数和一个对Rcpp函数执行循环的R函数。这些功能将在我的包裹里。如何构造R函数？根据上面的文章，用Rcpp函数构建第一个包会更容易一些--在R函数的第二个包中调用这个包。有办法将这两个函数放在同一个包中吗？
浏览 1提问于2019-11-12得票数 0
回答已采纳
我就是不能在并行的foreach中得到工作的ovun.sample。
下面是最小的工作示例。
library(doParallel)
library(ROSE) # ovun.sample
if(!getDoParRegistered()){
registerDoParallel(cores=detectCores())
}
foreach(i=1:2,.combine=rbind, .packages=c("ROSE")) %dopar% {
my_data = iris[iris$Species != "setosa",]
under_dat
浏览 0提问于2016-02-01得票数 1
1回答
doParallel比顺序处理慢
、、、、
我试图通过使用RStudio包并遵循教程，使并行处理在本地安装RStudio或在云上工作。
不幸的是，打开并行处理似乎会降低的计算速度，而不是加快它的速度。
测试操作：
microbenchmark(foreach(i=1:1000) %dopar% sum(tanh(1:i)))
system.time(foreach(i=1:1000) %dopar% sum(tanh(1:i)))
没有并行处理的结果
Unit: milliseconds
expr min lq mean media
浏览 3提问于2020-11-10得票数 0
我有一个很大的数据集(大约4000万行x 4列)，我想对每行中的数据执行一次Fisher测试。
数据示例如下所示：
refAppleBase altAppleBase refHawBase altHawBase
1 115 1 94 0
2 117 4 93 1
3 125 4 94 1
4 107 26 89
浏览 1提问于2019-01-07得票数 0
1回答
假设我有一个代码在foreach循环中执行各种计算，为了简单起见，让它如下所示：
foreach( idx = 1:10 ) %dopar% {
set.seed(idx)
smp <- rnorm(10)
print( sprintf('Index: %d', idx) )
print( cat(sprintf('Value: %f \n', smp[1:10])) )
}
代码的主要思想是，它的输出是这样写的，索引只显示一次，然后遵循主代码的各种结果。然后，在使用%do%时，很容易读取日志文件并使用这种结构进行调试，但是使用%d
浏览 3提问于2015-09-01得票数 1
回答已采纳
阅读的小插曲。
下面两个代码块是一个并且是相同的吗？
library(doparallel)
no_cores <- 8
cl <- makeCluster(no_cores)
registerDoParallel(cl)
pieces <- foreach(i = seq_len(length(pieces))) %dopar% { # do stuff}
上面的内容和下面的一样：
library(doparallel)
registerDoParallel(cores = 8)
pieces <- foreach(i = seq_len(lengt
浏览 36提问于2017-08-20得票数 1
回答已采纳
2回答
我一直在使用R中的“doParallel”库来提高一组函数的速度。但是，我遇到了一个我无法解决的错误。我相信以下代码隔离了问题的核心：
library(Matrix)
library(doParallel)
test_mat = Matrix(c(0,1,2,NA,0,0,2,NA,1,NA,1,2,2,NA,0,1,0,2,2,2,0,0,NA,NA,1,2,1,1,2,1,rep(NA,5)), ncol=7, byrow=TRUE, sparse=TRUE)
par_func <- function(mat, ncores)
{
cl <- makePSOCKclus
浏览 0提问于2014-06-13得票数 6
回答已采纳
我试图通过在R中使用doParallel包来减少代码的运行时间。
我正在调用一个函数awareRateSIR，该函数的主体中使用了一些额外的包。我遇到了一些错误
找不到函数"vcount“和.
我知道vcount是在awareRateSIR中使用的包igraph的一个函数)，但它并不是唯一的函数。我该如何解决这个问题？我认为应该传递函数awareRateSIR中使用的所有包名，但我不知道如何在foreach中导出多个函数，也不知道如何导出多个包名。
这是我的密码：
tp<-foreach(i=1:iter, .inorder = FALSE, .export =
浏览 3提问于2017-08-18得票数 10
回答已采纳
1回答
这基本上是对更专门的问题的跟进。在R中进行并行计算时，有一些关于僵尸进程创建的帖子。
并行计算有几种方法，我将重点介绍到目前为止在本地机器上使用的三种方法。我在带有doMC内核的本地计算机上使用了doParallel和foreach包：
(a)登记分叉组群：
library(doParallel)
cl <- makeForkCluster(4)
# equivalently here: cl <- makeForkCluster(nnodes=getOption("mc.cores", 4L))
registerDoParallel(cl
浏览 2提问于2014-08-19得票数 14
回答已采纳
我试图使用doParallel包来估计多个非参数模型。不过，我的问题似乎与np包有关。看看这个可复制的例子：
library(np)
library(doParallel)
df <- data.frame(Y = runif(100, 0, 10), X = rnorm(100))
models <- list(as.formula(Y ~ X))
npestimate <- function(m, data) {
LCLS <- npregbw(m, data = data, regtype = "lc", bwmethod = &#
浏览 0提问于2018-06-22得票数 3
回答已采纳
我正在尝试在doParallel中使用Rcpp module。然而，它们似乎是不兼容的。这是一个会产生segfault的例子。我也试过用R built-in reference class做类似的事情，它工作得很好。
require(doParallel)
require(Rcpp)
require(inline)
inc = '
using namespace Rcpp; class Uniform { public:
Uniform(double min_, double max_) : min(min_), max(max_) {}
NumericVector
浏览 1提问于2014-03-08得票数 0
1回答
我想把这个函数写成一个R包
编辑
#' create suns package
#''
#' More detailed Description
#'
#' @describeIn This sums helps to
#'
#' @importFrom foreach foreach
#'
#' @importFrom doParallel registerDoParallel
#'
#' @param x Numeric Vector
#'
#' @importFrom doPa
浏览 5提问于2021-07-19得票数 0
回答已采纳
在运行并行函数之后，我看到您必须使用stopCluster()：在R中的foreach()，但是，我可以不使用stopCluster()就可以使用registerDoParallel()，然后按照自己的意愿多次运行foreach()。我需要stopCluster()还是不需要？
不使用stopCluster()是否意味着您的核心被当前的任务占用了？所以，如果我使用的是并行编程，其间只有少量的单个核心顺序任务，那么我不需要stopCluster()？我知道设置并行也会占用大量的开销时间。
浏览 1提问于2018-10-25得票数 3
2回答
我开发了一个包含函数的R包。
我希望以一种对用户透明的方式来实现这些函数的并行化，而不管用户的操作系统是什么(至少在理想情况下)。
我环顾四周，看看其他包作者是如何导入的。例如，Max的caret包导入foreach以使用%dopar%，但在用户上导入以指定并行后端。(有几个例子使用doMC，它在Windows上不起作用。)
注意到适用于Windows和Linux/OSX，并且使用内置的parallel包(请参阅注释以获得有用的讨论)，当用户指定parallel=TRUE作为参数时，导入doParallel并让函数调用registerDoParallel()是否有意义？
浏览 4提问于2017-02-21得票数 7
回答已采纳
我试图在(UbuntuLTS16.04)上训练一个R插入模型的列表。xgboost ( xgblinear )模型花了很长时间才完成培训。实际上，从GCP状态监视中CPU利用率总是为0。
我使用doMC库进行并行执行。对于C5.0、glmnet和gbm这样的模型，它工作得很好。但是，对于xgboost ( xgblinear和xgbtree)，由于某种原因，CPU似乎没有运行，因为利用率保持在0。故障排除: 1.删除doMC，只运行单核，仍然存在相同的问题。2.将并行执行库改为doParallel而不是doMC。这一轮CPU利用率上升，但完成GCP培训需要5分钟。同样的代码在我的本地笔记本电脑
浏览 0提问于2019-06-09得票数 1
回答已采纳
1回答
我正在测试R下的，我想知道如何指定CPU核的数量。我只在python下找到tensorflow解决方案，没有keras。
> library(keras)
> library(doParallel)
> cl <- makeCluster(2)
> registerDoParallel(cl)
> is_keras_available()
[1]TRUE
> foreach(i=1:3) %dopar% { is_keras_available()}
Error in { :
task 1 failed - "impossible to
浏览 0提问于2018-03-01得票数 2
回答已采纳
2回答
假设我希望在foreach包中使用doParallel返回两个不同维度的数据帧的列表，如下所示：
a<-NULL
b<-NULL
for(i in 1:100){
a<-rbind(a,data.frame(input=i,output=i/2))
if(i > 5){
b<-rbind(b,data.frame(input=i,output=i^2))
}
}
list(a,b)
因为foreach返回一个对象，所以没有明显的方法(至少对我来说)可以使用foreach来完成上面的操作。
注意:这是我实际上正在处理的问题的简化版本，所以使用la
浏览 10提问于2014-12-03得票数 4
回答已采纳
4回答
doMC的文档看起来很稀疏，只列出doMC-包和registerDoMC()。我遇到的问题是，我会通过doMC/foreach培养出几个员工，但是当工作完成后，他们就会坐在那里回忆起来。我可以去寻找他们的进程I，但我经常意外地杀死主进程。
library(doMC)
library(foreach)
registerDoMC(32)
foreach(i=1:32) %dopar% foo()
##kill command here?
我尝试过使用registerDoSEQ()进行跟踪，但它似乎并没有扼杀进程。
浏览 2提问于2014-02-13得票数 7
回答已采纳
在Linux计算机上，继之后，我使用doParallel::registerDoParallel()，然后使用options(cores = N)，其中N是我想要与foreach一起使用的核数。
我可以用foreach::getDoParWorkers()验证，当我更改选项cores时，它会自动改变foreach使用的核数。
然而，在Windows10(最新版本的R和软件包)上，该选项似乎没有任何效果，因为更改其值不会改变foreach::getDoParWorkers()的值(在调用doParallel::registerDoParallel()时在3上初始化)。
可复制的例子：
doPar
浏览 0提问于2017-08-22得票数 4
回答已采纳
1回答
在我的代码中，一个方法被重复调用，但输入略有不同。该方法返回一个对象数组。这些调用中的每一个都要进行数千次计算。我想知道并行进程是否会有帮助？
一个示例方法(Scala伪代码)：
def method1(a: int, b: Float, c: Array[objX]): Array[objY] = {
…
}
对于这个示例，我需要在method1中运行三个变量：
val result = Array.ofDim[objY](3)
result(0) = method1(1, 1.1, A)
result(1) = method1(1, 1.5,
浏览 0提问于2020-09-20得票数 0
1回答
下面是我创建的函数的结构，其中实现了并行化。
parallelized.function <- function(...){
# Function used in the parallelization
used.in.par <- function(...)
# Function needed by used.in.par (auxiliars)
aux1<-function(...)
aux2<-function(...)
#
浏览 3提问于2017-03-30得票数 0
回答已采纳
2回答
我在for循环环境中使用函数"cop.theta“创建矩阵的代码。
Mat.corr <- matrix(0,6,5,byrow=F)
for (i in 1:6){
Mat.corr[i,]=cop.theta(index,EXPR,SURV=survp[,i])
}
我在doParallel包中使用"foreach“编写了一个R代码，以获得与上面生成的代码类似的结果。我的代码如下
library(doParallel)
cl <- makeCluster(3)
registerDoParallel(cl)
getDoParWorkers()
clusterEx
浏览 5提问于2016-04-06得票数 0
回答已采纳
1回答
我对R中的并行计算非常陌生，我希望(原始问题的非常简化的版本)通过以下方式为X，Y和Z添加一个新值：
library(foreach)
library(doParallel)
X <- 0
Y <- 0
Z <- 0
cores <- detectCores()
cl <- makeCluster(cores[1] - 1) #not to overload your computer
registerDoParallel(cl)
A <- foreach(i = 1:3, .combine = data.frame) %dopar% {
X = X
浏览 1提问于2017-11-29得票数 0
1回答
假设我有一个8核心CPU。在R中使用doParallel，当我注册makeCluster(x)时，理想的核数x是多少？
有尽可能多的核心吗？还是使用7个核心比使用6个核心要慢？关于这件事有什么规定吗？
浏览 2提问于2017-03-06得票数 5
1回答
我有一个矩阵，我在这个矩阵上计算列之间的相关性。我创建了一个函数，它以相关矩阵的形式给出结果(因为使用了apply()函数)，但我希望直接获得成对的相关数据帧。有没有可能在没有任何中间矩阵的情况下做到这一点:矩阵->成对相关数据帧 cor_rho<-function(y) {
res <- foreach(i = seq_len(ncol(y)),
.combine = rbind,
.multicombine = TRUE,
.inorder = FALSE,
.packages = c('data.table', 'doParallel'
浏览 23提问于2019-05-09得票数 1
回答已采纳
1回答
R个并行循环
、、
我正在尝试在R中开始并行化工作负载，因为我只是接近这种编写代码的新方法，所以我做了一些基准测试，以了解这可能会有多有效。
下面是代码：
library(doParallel)
library(doSNOW)
library(foreach)
library(tictoc)
no_cores <- detectCores() - 1
cl <- makeCluster(no_cores)
registerDoParallel(cl)
tic()
result <- foreach(i=1:10000,.combine=c) %dopar%{
i^2
}
to
浏览 0提问于2018-08-23得票数 1
回答已采纳
2回答
如何让R使用更多的CPU使用率？
、、、、
我注意到R并没有占用我所有的CPU，我想把它大大地增加(提高到100%)。我不希望它只并行化几个函数；我希望R使用更多的CPU资源。我正在尝试使用lp()函数运行一个纯IP集合打包程序。目前，我运行的是windows操作系统，我的电脑上有4个内核。
我尝试过使用snow、doParallel和foreach (尽管我不知道我到底在用它们做什么)。
在我的代码中我有这样的代码...
library(foreach)
library(doParallel)
library(snowfall)
cl <- makeCluster(4)
registerDoParallel(cl)
sfIn
浏览 4提问于2015-08-09得票数 6
我是拟合随机森林模型使用包插入和护林员，并试图加快使用并行进程。然而，速度增益很小。我正在使用的MacBook Pro (Retina，13英寸，2013年底)，2.4 GHz英特尔核心i5，8 GB 1600 MHz DDR3，macOS塞拉利昂10.12。可复制的例子：
library(caret)
library(mlbench)
data("Sonar")
start <- Sys.time()
mod_1 <- train(Class ~ ., data = Sonar, method = "ranger", num.trees = 10
浏览 1提问于2017-03-03得票数 1
回答已采纳
1回答
我正在尝试使用doParallel将function应用到data.frame的每一行，而不是使用apply。我早些时候在这里发布了一个关于这个问题的问题： doParallel instead of apply 我之前问题的答案适用于我当时提供的示例，但不适用于下面的示例。在我当前的示例中，我创建了一个简单的function，对于一个data.frame的每一行，只需将另一个data.frame的columns重命名。如果我不重命名function中第二个data.frame的columns，那么发布到我前面问题中的答案是有效的。 这是第一个data.frame df1 <- rea
浏览 59提问于2021-11-11得票数 2
回答已采纳
1回答
来自插入符号R包的parRF不适用于我的多个核心，这是相当讽刺的，因为在parRF中的标准代表平行。我在windows机器上，如果这是相关信息的话。我检查了一下，我使用的是关于插入符号和doParallel的最新版本。
我做了一个最小的例子，并给出了下面的结果。有什么想法吗？
源代码
library(caret)
library(doParallel)
trCtrl <- trainControl(
method = "repeatedcv"
, number = 2
, repeats = 5
, allowParallel = TRUE
)
# W
浏览 4提问于2014-07-16得票数 8
回答已采纳
这是我的代码。循环中的内容是有意义的。
library(foreach)
library(doParallel)
cl <- makeCluster(7)
registerDoParallel(cl)
elasticitylist = foreach(i=1:nhousehold) %dopar% {
pricedraws = out$betadraw[i,12,]
elasticitydraws[,,i]= probarray[,,i] %*% dia
浏览 1提问于2015-02-13得票数 32
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
