R - どのように私のmergesortを並列化する

Question

私は私のマージをしようとしているparallelの代わりに、私は並列ライブラリを使用しようとしましたが、動作しません（私は正確にそれを使用する方法を知らないその内部にマージ機能を入れるが、私の入力では機能しない）。

1行に1文字列のtxtファイルを入力してソートする必要があります。

これは私のシーケンシャルコードです：

#start time 
strt<-Sys.time() 

#merge sort 
mmerge<-function(a,b) { 
r<-numeric(length(a)+length(b)) 
ai<-1; bi<-1; j<-1; 
for(j in 1:length(r)) { 
    if((ai<=length(a) && a[ai]<b[bi]) || bi>length(b)) { 
    r[j] <- a[ai] 
    ai <- ai+1 
    } else { 
    r[j] <- b[bi] 
    bi <- bi+1   
    } 
} 
r 
} 

mmergesort<-function(A) { 
    if(length(A)>1) { 
    q <- ceiling(length(A)/2) 
    a <- mmergesort(A[1:q]) 
    b <- mmergesort(A[(q+1):length(A)]) 
    mmerge(a,b) 
} else { 
    return(A) 
} 
} 

#!/usr/bin/env Rscript 
args = commandArgs(trailingOnly=TRUE) 

# args test 
if (length(args)==0 | length(args)==1) { 
stop("Arquivo de entrada e saida devem ser fornecidos (input.txt, output.txt)", call.=FALSE) 
} 

#read file 
input <- read.table(file=args[1], header=F) 

#vector parser 
input <- as.character(input[,1]) 

#sort 
ordenado <- mmergesort(input) 

#write file 
write(ordenado, file=args[2], sep = "\t") 

#end time 
print(Sys.time()-strt) 

Answer 1

私は（uは単にコードの一部をしたい場合は13に行く：00-14：00）：thisビデオに従った後、それは使用して作られた

library(foreach) 
library(doParallel) 

[...] 

#merge sort 
mmerge<-function(a,b) { 
    r<-numeric(length(a)+length(b)) 
    ai<-1; bi<-1; j<-1; 
    foreach(j= 1:length(r)) %do% { 
    if((ai<=length(a) && a[ai]<b[bi]) || bi>length(b)) { 
     r[j] <- a[ai] 
     ai <- ai+1 
    } else { 
    r[j] <- b[bi] 
    bi <- bi+1   
    } 
} 
    r 
} 

[...] 

#number of clusters 
registerDoParallel(4) 

#sort 
ordenado <- mmergesort(input) 

#stop parallel 
stopImplicitCluster() 

[...]