병렬 실행 체인 연결 명령

Question

이 시나리오에 적합한 패턴을 찾고 있습니다.

이런 방식으로 HDD의 프로세스 파일이 필요합니다.

1. 로드 파일
2. 이 결과를
3. 가져 오기 파일을 분석을 기반으로 파일을
4. 검증 파일을 분석하여 향후 변화 될 수 있습니다 검증 결과

이 프로세스를 기반으로 앱.

제 아이디어는 각 파일 작업 (명령 패턴)에 대한 create 명령입니다.

• LoadFileCommand는 :
• AnalyzeFileCommand IFileCommand : IFileCommand를
• ValidateFileCommand : IFileCommand
• ImportFileCommand : IFileCommand

코드 :

public interface IFileCommand 
{ 
    FileCommandResult Execute(); 
    void Abort(); 
} 
public class FileCommandResult 
{ 
    FileInfo File{get;} 
    bool Sucesss{get;} 
    string Error{get;} 
} 

내가 명령으로 프로세스를 생성해야합니다 s (명령이있는 체인).

나는이 목적으로 사용하려고 시도한다. 패턴의 체인이 좋지만 아마도 더 좋은 패턴이나 디자인이있을 수 있습니다.

가능하다면 Rx를 사용하고 병렬 실행도 좋을 것입니다.

나는이를 싶습니다

var data = new List<FileInfo>(); 

var process = new List<IFileCommand>{new LoadFileCommand(), new AnalyzeFileCommand(), new ValidateFileCommand(), new ImportFileCommand()}; 

var processor = new FileProcessor(); 

IEnumerable<IFileCommandResult> results = processor.Execute(process, data); 

어떤 아이디어.

Answer 1

왜 Rx를 사용 하시겠습니까? 작업을 일련의 명령으로 나타내려면 LINQ를 사용하여 명령 체인을 적용하면됩니다. 병렬로 실행하려면 PLINQ, TPL 또는 Parallel.ForEach를 사용하십시오. TPL Dataflow을 살펴볼 수도 있습니다.

다음은 문제를 해결하는 3 가지 방법입니다. 참고 오류 처리를 구현하지 않았거나 Abort 메서드를 사용하여 엉망이되어 사용하지 못 했으므로 Execute 메서드로 몇 가지 자유를했습니다. 이제 Execute에이 서명이 있다고 가정하고 FileInfo Execute(FileInfo)과 실패하면 예외를 throw합니다.

IEnumerable<FileInfo> data = ...; 
IEnumerable<IFileCommand> process = ...; 

// PLINQ 
var results = data 
    .AsParallel() 
    .Select(dataItem => process.Aggregate(dataItem, (d, p) => p.Execute(d))) 
    .ForAll(dataItem => import(dataItem)); 


// Parallel.Foreach 
Parallel.Foreach(data, dataItem => import(process.Aggregate(dataItem, (d, p) => p.Execute(d)))); 

// TPL 
var tasks = data 
    .Select(dataItem => Task.Run(() => import(process.Aggregate(dataItem, (d, p) => p.Execute(d))))); 
await Task.WhenAll(tasks);