スレッディングとSOLID原則

Question

私はだから私は私のメインクラスで新しいタスクを作成したデータは、それが入ってくるように、データをキューするDataInCollectionに追加され、私たちは」次のコードのセットアップ

public interface ILogger 
{ 
    void WriteData(string Data); 
} 

public class Logger : ILogger 
{ 
    public void WriteData(string Data) 
    { 
    //Write to disk 
    } 
} 

public interface ILogic 
{ 
    void ProcessData(string Data); 
} 

public class Logic : ILogic 
{ 
    private ILogger Logger; 

    public Logic(ILogger Logger) 
    { 
    this.Logger = Logger; 
    } 

    public void ProcessData(string Data) 
    { 
    //Do stuff 
    Logger.WriteData("Data to write"); 
    } 
} 

public class MainEntryPointClass 
{ 
    private BlockingCollection<string> DataInCollection; 
    private Task DataInTask; 
    private CancellationTokenSource CancellationTokenSource; 

    public Start() 
    { 
     InitializeDataIn(); 
    } 

     private void InitializeDataIn() 
     { 
      CancellationTokenSource = new CancellationTokenSource(); 
      DataInCollection = new BlockingCollection<DataInContents>(); 
      DataInTask = Task.Factory.StartNew(() => ProcessDataIn(CancellationTokenSource.Token)); 
     } 

     private void ProcessDataIn(CancellationToken CancelToken) 
     { 
      while (!CancelToken.IsCancellationRequested) 
      { 
       foreach (var item in DataInCollection.GetConsumingEnumerable()) 
       { 
        Logic.ProcessData(item); 
       } 
      } 

     } 
} 

を持っています30ミリ秒ごとに話をする。これは正常に処理されます。

私は今、別のスレッドでファイルにデータを書きたいと思っています。そのため、ディスクに問題がある場合、メインロジックのチェックには影響ありません。ディスクに問題がある場合は、ロジックを続行できます。私は別のスレッドでファイルの書き込みをどこで行うのか分かりません。 Mainクラス、Logicクラス、Loggerクラスのどちらですか？

Answer 1

Loggerは、発信者をブロックしないようにする責任があります。それには、さまざまな戦略を使用できます。あなたはそれらの戦略をそれを使用するクラスに焼きたいとは思わない。

私はメッセージをBlockingCollection<T>にエンキューし、1つのIOスレッドでディスクに書き込むようにしました。

Common.Logging's ILogのような既存のロギングインターフェイスを模倣することをお勧めします。「サードパーティなし」の要件がなくなると、既存のログフレームワークに簡単に切り替えることができます。

ような何か：

class AsyncLogger:ILogger 
{ 
    public AsyncLogger(ILogger backingLogger) 
    { 
    new Thread(()=> 
     { 
     while(true) 
     { 
      var data=_queue.Take(); 
      _backingLogger.WriteData(data); 
     } 
     } 
    ).Start(); 
    } 

    public void WriteData(string data) 
    { 
    _queue.Enqueue(data); 
    } 
} 

多分この質問のためのロガー・インプリメンテーションをされて使用して

Answer 2

ロガークラスはロギングを担当します。したがって、受信データをディスクに記録するのに適しているようです。