일부 병렬 작업과 일부 연속 작업이있는 메서드에 대한 작업 병렬 라이브러리

Question

일련의 메서드 호출을 포함하는 메서드가 있습니다. 이러한 메서드 호출 중 일부는 한 번에 발생할 수 있으며 일부는 순차적으로 수행해야합니다. 작업 병렬 라이브러리에서이를 구현하는 가장 직접적인 방법은 무엇입니까? 모든 기능은 계산이 무거워서 실행하는 데 1 초도 채 걸리지 않습니다. 즉

public object MyMethod(InputClass myInput) 
{ 
    var result = method1(myInput); 
    var result1 = method2(result); 
    var result2 = method3(result); 
    var finalResult = method4(result1, result2); 
    return finalResult; 
} 

방법 항목이 실행되어야 1, 방법 2 +의 Method3 병렬로 실행될 수 method4 최후 실행되어야한다.

Answer 1

나는 이것이 당신이 요구하는 병렬 처리 수준을 제공 할 것이고, 방법 2와 3은 동시에 실행될 것이라고 믿습니다.

public void MyMethod(InputClass myInput) 
{ 
    TaskFactory<object> t = new TaskFactory<object>(); 

    var result = method1(myInput); // Execute Synchronously 

    Task<object> t1 = t.StartNew(method2, result); // Create and start new concurrent task 
    Task<object> t2 = t.StartNew(method3, result); // Create and start new concurrent task 

    t1.Wait(); //Wait for completion 
    t2.Wait(); //Wait for completion 

    var finalResult = method4(t1.Result, t2.Result); // Execute Synchronously 
} 

편집 : 업데이트 몇 가지 유형, 가정의 모든 방법은 object을 반환합니다.

Answer 2

ContinueWith를 사용하여 아래와 같이 순차 실행을 지정할 수 있습니다.

TaskFactory myFactory = new TaskFactory(); 

myFactory.StartNew(method).ContinueWith(delegate 
{ 
    Task t1 = myFactory.StartNew(method2); 
    Task t2 = myFactory.StartNew(method3); 

    myFactory.ContinueWhenAll(new [] {t1, t2}, method4); 
}); 

Answer 3

F #의 비동기 블록과 새로운 비동기 CTP는 이러한 문제를 깨끗하고 효과적으로 해결하여 동시 파이프 라인의 외부 구성을 허용하도록 설계되었습니다. 네가 TPL을 말한 건 알지만, 네가 한 번 봐봐.

async { 
    let! result = method1 myInput 
    let! result1 = method2 result 
    let! result2 = method3 result 
    let! finalResult = method4 result1 result2 
}