parallel-foreach

    3熱度

    1回答

    我已經編寫了一個運行良好的腳本,但它似乎並沒有進行並行處理。我嘗試將內核從3改爲16,但數據生成速度沒有改變。任何人都可以讓我知道我做錯了什麼,以及我如何才能使其工作? setwd("E:/Infections") if (!require("pacman")) install.packages("pacman") pacman::p_load(lakemorpho,rgdal,maptoo

    1熱度

    1回答

    我是一個用R並行計算的初學者。我最近開始使用使用doParallel包的foreach和並行計算。當我試圖在將迭代器拆分爲塊時將列表編入索引時,我遇到了一個問題。 library(itertools) library(foreach) library(doParallel) n=10000 iter = 1:n cores = detectCores() -1

    1熱度

    1回答

    我正在運行一個相當長的工作,我需要重複100次,因此我轉向了R中的foreach功能,然後通過一個8核羣集shell腳本。我試圖將每次運行的所有結果輸入到同一個文件中。我已經包含了我的代碼的簡化版本。 cl<-makeCluster(core-1) registerDoParallel(cl,cores=core) SigEpsilonSq<-list() SigLSq<-list() R

    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回答

    我想將foreach包與日誌記錄結合使用。我通常使用futile.logger包。當工作給予工人日誌信息丟失 我見過this post(因爲你需要指示的foreach logging包這是奇怪),但它不使用的foreach library(foreach)

    1熱度

    1回答

    我使用foreach包來並行化一些東西,並且我厭倦了每次需要使用它時都會在.export中指示5個函數。 我知道我可以做foreach(...,.export=ls(.GlobalEnv)),但這會將大量數據傳輸給工作人員,並減慢我的速度(可以定義大表格)。 所以,問題是我怎麼能只列出在.GlobalEnv 我做函數: getAllFunctions <- function(envir=.Glob

    0熱度

    1回答

    我有一個大約25L行的數據集,其中應用了此功能「狀態」。它是一個標記程序。在fn內部,矢量化操作並使用應用函數。 c1-c4是我數據中的列。大約需要5-6小時才能執行fn。 status(mydata) status <- function (x) { x<- subset(x, x$RECORD_TYPE != "INPUT") x$c1<- as.character(x$c1) x$

    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>

    13熱度

    1回答

    並行循環我有一個for循環,是這樣的: for (i=1:150000) { tempMatrix = {} tempMatrix = functionThatDoesSomething() #calling a function finalMatrix = cbind(finalMatrix, tempMatrix) } 你能告訴我如何使這個並行? 我試過這