parallel-foreach

    0热度

    1回答

    我有一个函数,我动态地建立多个公式作为字符串,并将它们投射到公式为as.formula。然后我使用doSNOW和foreach以并行处理的方式调用该函数,并通过dplyr::mutate_使用这些公式。 当我使用lapply(formula_list, as.formula)时,在并行运行时出现错误could not find function *custom_function*,但在本地运行时工

    1热度

    1回答

    我R中作了如下顺序迷你例如: all_list <- list() all_list[1] <- list(1:6000) all_list[2] <- list(100000:450000) all_list[3] <- list(600000:1700000) all_list[4] <- list(2000000:3300000) all_list[5] <- list(36000

    1热度

    1回答

    我在下面的示例代码中使用了foreach和doParallel。 library(foreach) library(doParallel) clusters = makeCluster(4) registerDoParallel(clusters) fun1 <- function(param1, param2, param3) {

    -1热度

    2回答

    使用在并行处理共享数据帧我想使用的foreach包并行for循环: 原始的代码如下所示: data_df=data.frame(...) # the data frame where original data stored result_df=data.frame(...) # the data frame where result data to be stored for(i in 1

    1热度

    1回答

    在接下来的循环中,我要添加的逻辑说,如果处理器1,那么做到这一点,如果处理器2做等等。我一直在尝试不同的属性,如... Console.WriteLine("Domain ID = " + Thread.GetDomainID().ToString()); Console.WriteLine("Thread ID = " + Thread.CurrentThread.ManagedThreadI

    0热度

    2回答

    使用foreach和doRedis时,doRedis工作人员将等待所有作业都到达redis服务器,然后再开始处理。是否有可能在所有预处理完成之前开始它们? 我正在使用一个工作良好的迭代器 - 预处理恰好在'及时'并且作业数据开始在迭代器运行时启动服务器。但是,我似乎无法利用这种行为,因为工作人员只是等到所有工作都上传完毕。 示例代码: library(foreach) library(doRed

    5热度

    1回答

    我想读取文本文件中的所有行,并计划显示每行信息。我如何找到循环内的每个项目的索引? string[] lines = File.ReadAllLines("MyFile.txt"); List<string> list_lines = new List<string>(lines); Parallel.ForEach(list_lines, (line, index) =>

    1热度

    1回答

    我想获得并行运行代码的总CPU小时数(使用包doParallel中的foreach),但我不确定如何去做这件事。我使用proc.time(),但它只是返回“真实”时间的差异。从我所读到的system.time()中,它也应该和proc.time()一样。我如何获得并行运行的R代码的总CPU时间?

    0热度

    1回答

    高效,选择性地组合列,我有以下数据 countrycols = alljson[,c("country_gc_str","country_ipapi_str","country_tm_str")] head(countrycols) country_gc_str country_ipapi_str country_tm_str 1 <NA> RU RU 2 <NA>

    1热度

    1回答

    正如标题所暗示,我感到困惑的是两个包之间的区别,因为他们都在并行计算应用于R.