src/LanSpider/Multithreading/Consumer.cs

   1 using System;
   2 using System.Collections.Generic;
   3
   4 namespace LanSpider.Multithreading
   5 {
   6     /// <summary>
   7     /// Consumes work items produced by WorkManager.
   8     /// </summary>
   9     public class Consumer< TResult >
  10     {
  11         private List<TResult> _results;
  12         private readonly object _resultsLock = new object();
  13
  14         public IEnumerable<TResult> Results
  15         {
  16             get
  17             {
  18                 if ( _results == null )
  19                 {
  20                     throw new InvalidOperationException( "Cannot return results before work was preformed" );
  21                 }
  22
  23                 return _results;
  24             }
  25         }
  26
  27         public void Consume( TResult result )
  28         {
  29             lock ( _resultsLock )
  30             {
  31                 if ( _results == null )
  32                 {
  33                     _results = new List<TResult>();
  34                 }
  35
  36                 _results.Add( result );
  37             }
  38         }
  39     }
  40 }