병렬 foreach 흐름 제어

Question

Parallel.ForEach을 사용하여 두 가지 작업을 실행해야하지만 첫 번째 작업을 완료하고 다음에 두 번째 작업을 시작해야합니다. 코드 업데이트 및 마지막으로 업데이트 된 레코드에 대한 Task2 검사 (에서 사람들을 필요로하는 DB에 일부 레코드에 대한

Task1 검사 꽤 큰 그대로

Parallel.Foreach(items, (item, state) => 
{ 
    Task1(item); 
    Task2(item); 
} 
public void Task1(Item item) 
{ 
    var records = GetRecordsToExport(); 
    UpdateFields1(records); 
} 
public void Task2(Item item) 
{ 
    var content = File.Read(...); 
    // read every line in content, and for every line update field DB 
    foreach(var c in content) 
    { 
     UpdateFields2(c); // different methods 
    } 
} 

이 코드는, 내가 더 게시 할 수 없습니다 Task1)을 선택하고 다시 업데이트합니다.

처음에는 프로그램이 충돌하는 이유를 찾을 수 없었습니다. 하나의 타스크가 다른 타스크가 완료되기 전에 시작 되었기 때.에 동일한 타스크 테이블에서 작동하기 때.입니다. 실행 순서를 어떻게 제어 할 수 있습니까?

Answer 1

Task1에서 실행중인 스레드가있는 동안 수행 할 수있는 작업은 Task2에 대한 액세스를 차단하는 것입니다. 그리고 다른 방법으로 Task2가 실행 중일 때 Task1을 입력 할 수있는 스레드가 없습니다.

var lock = new ReaderWriterLockSlim(); 


Parallel.Foreach(items, (item, state) => 
{ 
    lock.EnterReadLock(); 
    try { 
     Task1(item); 
    } finally { 
     lock.ExitReadLock() 
    } 
    lock.EnterWriteLock(); 
    try { 
     Task2(item); 
    } finally { 
     lock.ExitWriteLock() 
    } 
} 

또한 어떤 Task2 방법을 방지 할 수 있습니다이 코드는 두 번 입력해야합니다 :

나는 당신이 ReaderWriterLockSlim 사용하려고 할 수 있다고 생각합니다. 필요한 경우 세마포 또는 뮤텍스를 사용해 볼 수 있습니다. 하지만 이렇게하면 더 복잡해질 것입니다. Task2가 작업 1이 아직 처리가 완료되지 않은하는 항목에서 작동하는

Answer 2

그것은 불가능합니다

public class Test 
{ 
    private static object syncObj = new object(); 

    public static void Main() 
    { 
     var items = Enumerable.Range(0, 100).ToArray(); 
     Parallel.ForEach(items, (item, state) => 
     { 
      Task2(Task1(item)); 
     }); 
    } 

    static int Task1(int item) 
    { 
     Console.WriteLine("Task 1 : {0}", item); 
     Thread.Sleep(100); 
     return item; 
    } 

    static int Task2(int item) 
    { 
     Console.WriteLine("Task 2 : {0}", item); 
     return item; 
    } 
}