parallel-processing

0热度

1回答

我有一个问题，而我试图恢复已经由parLapply算法R. ejecuted数据帧I附着有虹膜数据设置为显示该问题的下一个例子。我创建了一个函数，为每个虹膜种类做一个线性模型，然后通过它们循环。 uniques<-unique(iris$Species) model<-function(i){ table<-iris[iris$Species==uniques[i],]

1热度

1回答

使用R并行处理

我有一个可以简化为简单版本的r代码，如下所示。 cl <- parallel::makeCluster(2, type="SOCK") b<-data.frame(c(1,1,2,2,3,3,4,4,7,7,9,9,11,11,12,12,13,13,14,14)) colnames(b)<-c("col1") b_uni<-unique(b) clusterExport(cl,"b_un

0热度

1回答

如何将单个节点的多个内核分配给MPI群集中的单个作业/进程？

我有一个MPI程序，我想在30个节点上运行（每个节点有32个内核）。我如何将一个节点的所有内核分配给单个作业/进程？我正在使用插槽来限制特定节点的作业数量。 node001 slots = 1 max_slots = 20 node002 slots = 1 max_slots = 20 是否有任何参数可用于实现此目的？在此先感谢。

0热度

2回答

Parellel编程：我如何申请'MPI_Gather'或'MPI_Scatter'而不是'MPI_Isend'和'MPI_Recv'

这是我计算素数的代码，我只想在这些过程中使用集体通信。但是，当我使用'MPI_Scatter'和'MPI_Gather'而不是MPI_Recv和MPI_Isend更改我的代码时，出现错误。我应该改变什么？这是我的原代码： MPI_Request req; MPI_Status status; MPI_Init(&argc,&argv); MPI_Comm_size(MPI_COMM_WOR

0热度

1回答

在shell命令R中的并行计算

我有用例，我试图通过一堆文件运行我的Rscript调用。我写下下面的代码片段 - for(i in 1:length(fileNames)){ generateTolerancesCommand = paste(c("Rscript ",modelScriptName, " --inp=",paste(c("'",dimensionsFolder, "/",

4热度

1回答

我可以在bash中为多个并行后台进程使用相同的变量名吗？

在下面的shell脚本中，我想在后台并行运行2条命令来加速进程，等待它们完成，然后继续运行更多命令。因为我在两个循环中使用相同的变量名称（DATASERVERNAME），这些变量是否会在后台互相干扰？我应该在每个循环中使用不同的变量名称，例如DATASERVERNAME_SYBASE，DATASERVERNAME_ORACLE吗？ #!/bin/bash while read DATASERV

2热度

2回答

在Julia中进行异步多重计算的并行代码

我知道这可能在过去被问过，但我是Julia的绝对初学者。我有一个简单的代码在朱莉娅，我想并行运行。 #--Two Calculations during the Loop-- vt_0=0 ct_0=0 for i=1:10 #--Calculation vt_1 vt_1=max(rand(1:i),vt_0,ct_0) #--Calculation ct_1 ct_1

1热度

3回答

如何同步不同的shell实例

我想同步/“顺序化”同时运行特定shell的多个实例。可选地，参数的子集可以确定进程是否可以立即运行或必须等待。要明确：如果我同时运行以下三个命令（在这个例子中schema和table选项确定锁）： loadTable --schema dev --table person --file mydata1.txt loadTable --schema dev --table person -

0热度

1回答

的Java与平行阵列

我写了一些代码，把我的假后，它编译，但输入项目名称和成本后的第一时间，然后再命名它引发的输入错误的比赛异常的错误。我不知道为什么。 import java.util.Scanner; public class NewAssignment { public static void main(String args[]){

0热度

1回答

Python：Joblib中的并行处理使代码运行速度更慢

我想集成并行处理以使我的for循环运行得更快。但是，我注意到它只是让我的代码运行得更慢。请参阅下面的示例，其中我使用joblib，并在随机整数列表上使用了简单函数。请注意，没有的并行处理运行速度快于和。任何有关正在发生的事情的见解？ def f(x): return x**x if __name__ == '__main__': s = [random.randint(