작업 실행 실패

Question

큰 텍스트 파일을 읽고 검색어가 포함 된 줄을 검색하는 작은 유틸리티를 작성했습니다. 나는 이것을 TPL Dataflow를 배울 수있는 기회로 삼고있다.

검색 용어가 파일의 맨 끝에 있지 않으면 코드가 제대로 작동합니다. 이 경우 uiResult 작업 블록은 이 아니며에 중단 점이 없으면 호출되지 않습니다.

내 이해 데이터 searcher (이것은 데이터의 마지막 블록이 처리 된) 완료된다searcher 후, 에서 uiResult에 게시되어있다. 데이터는 uiResult에 게시되었으므로 해당 데이터가 처리 될 때까지 완료되지 않아야합니다.

질문

왜 uiResult 데이터가 여기에 게시 된 경우에도 완료 될 것입니다 (중단 점은 uiResult 설정하지 않는 한)? 가능한 한 다시 손질로

코드

여기에서 관련 코드입니다 :

ActionBlock<LineInfo> uiResult = new ActionBlock<LineInfo>(li => 
    { 
     // If match found near end of file, the following line only runs 
     // if a breakpoint is set on it: 
     if (results != null) results.Add(li); 
    }, 
    new ExecutionDataflowBlockOptions() 
    { 
     MaxDegreeOfParallelism = 1, 
     CancellationToken = cancelSource.Token, 
     TaskScheduler = TaskScheduler.FromCurrentSynchronizationContext() 
    }); 

BatchBlock<LineInfo> batcher = new BatchBlock<LineInfo>(5000); 

ActionBlock<LineInfo[]> searcher = new ActionBlock<LineInfo[]>(lines => 
    { 
     foreach (LineInfo li in lines) 
     { 
      if (li.TextOfLine.Contains(searchTerm)) 
      { 
       uiResult.Post(li); 
      } 
     } 
    }, 
    new ExecutionDataflowBlockOptions() 
    { 
     MaxDegreeOfParallelism = 1, 
     CancellationToken = cancelSource.Token 
    }); 

batcher.LinkTo(searcher); 

batcher.Completion.ContinueWith(t => 
{ 
    if (t.IsFaulted) ((IDataflowBlock)searcher).Fault(t.Exception); 
    else searcher.Complete(); 

    if (t.IsFaulted) ((IDataflowBlock)uiResult).Fault(t.Exception); 
    else uiResult.Complete(); 
}); 

Task.Run(() => 
    { 
     using (FileStream fs = File.Open(filePath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite)) 
     using (BufferedStream bs = new BufferedStream(fs)) 
     using (StreamReader sr = new StreamReader(bs)) 
     { 
      string line; 
      while ((line = sr.ReadLine()) != null && cancelSource.IsCancellationRequested == false) 
      { 
       batcher.Post(new LineInfo() { LineNumber = lineNumber, OffsetOfLine = offset, TextOfLine = line }); 
      } 

      batcher.Complete(); 
      try 
      { 
       searcher.Completion.Wait(); 
       uiResult.Completion.Wait(); 
      } 
      catch (AggregateException ae) 
      { 
       TaskCanceledException taskCancelled = ae.InnerException as TaskCanceledException; 
       if (taskCancelled != null) 
       { 
        // Swallow the Exception if is just a user cancellation 
        throw; 
       } 
      } 
      finally 
      { 
       signalDone(); 
      } 
     } 
    }); 

Answer 1

귀하의 코드가 있기 때문에 당신이 완료를 처리하고있는 방식의 비 결정적이다.

1. Task 프로세스 전체 파일 및 batcher에 Complete()를 호출하여 이벤트의 가능한 순서는 이것이다.
2. batcher은 마지막 배치를 처리하여 searcher으로 전송하고 완료합니다.
3. 및 uiResult에서 Complete()을 호출하는 연속이 실행됩니다.
4. uiResult에는 할 일이 없으므로 완료됩니다.
5. searcher은 각 결과를 uiResult으로 보내려고 마지막 배치를 처리합니다. 그러나 uiResult은 이미 완료되었으므로 모든 것을 거부합니다. 즉, Post()은 false을 반환하지만이를 확인하지는 않습니다.

그래서 문제는 이미 완료된 블록으로 무언가를 보내려고한다는 것입니다. 이는 효과가 없습니다.

해결책은 완료되기 전에 블록 (즉, Completion이 완료 됨) 이후에만 블록에 Complete()을 호출하는 것입니다. 아마도 가장 쉬운 방법은 PropagateCompletion을 LinkTo()과 함께 사용하는 것입니다.