r pthread-like functions

Question

R로 멀티 스레딩을하고 싶습니다. 저는 C pthread 기능에 익숙합니다. 내가하고 싶은 것입니다 :

#initialisation 
n=10 
A <- numeric(n) 

i=c(1:n/2) 

# compute some indexes using the one function fun1 
# equivalent in C with correct initialisation of t1 and attr: 
## pthread_create(&t1, &attr, fun1, i) 
A[i] <- fun1(length(i)) 

# compute other indexes using another function fun2 
# equivalent in C with correct initialisation of t2 and attr: 
## pthread_create(&t2, &attr, fun2, i) 
A[-i] <- fun2(n-length(i)) 

# wait for the thread to finish 
# equivalment in C: 
## pthread_join(t1); pthread_join(t2) 

# do something with the result 
A 

두 함수 fun1 및 Fun2에 내가 다음 단계를 수행하기 전에 완료해야하는 모든 스레드를 기다려야 원하는대로 사용 fork()이 적절하다고 생각하지 않는 완전히 독립적이다. 2 개의 함수 fun1과 fun2의 결과와 함께.

Answer 1

• i을 반복합니까? 그렇다면 각 i에 대해 fun1 및 fun2을 이상적으로 평가할 수 있습니까? 이 경우 패키지와 함께 병렬 백엔드 doMC과 함께 i을 통해 루프를 구성하십시오.

  그렇지 않으면

  require(foreach) 
  require(doMC) 
  A <- foreach(i = 1:(n/2), .combine=rbind) %dopar% {c(fun1(i),fun2(i))} 
  

• 처럼 fun1fun2의

  switchingFun <- function(.., selFun=1){ 
      if(selFun == 1){ fun1(...)} else {fun2(...) 
  } 
  

  는 또한 fun1 및 Fun2에있는 arguemnts와 목록을 구축 실행하는 그것을 말하고, 당신이 스위치를 통과하는 pseudofunction를 구축합니다. 그리고 이것을 루프 foreach(selFun in 1:2) %dopar% {switchingFun(arguments[[selFun]], selFun)}에 넣으십시오. (...은 매우 유용합니다. 그냥 시도해 보았습니다.)

  호출하는 함수를 살펴보아야 할 수도 있습니다. 전달하기 전에 인수 목록에 무엇인가를해야 할 수도 있습니다. 유형, disentangle 그것 ...) switchingFun 기능.

• A[-i]은 원하는대로 작동하지 않습니다. R에서 A[-i] 말을하는 것은 모든 요소를 ​​선택 하지 i에 의해 색인 ... 당신은 R.에서 병렬화에 대한 연구를 한 것은 보이지 않는다