code.grnet.gr Git - pithos-ms-client/blob - trunk/Pithos.Core/JobQueue.cs

   1 // -----------------------------------------------------------------------
   2 // <copyright file="JobQueue.cs" company="GRNet">
   3 // Copyright 2011-2012 GRNET S.A. All rights reserved.
   4 //
   5 // Redistribution and use in source and binary forms, with or
   6 // without modification, are permitted provided that the following
   7 // conditions are met:
   8 //
   9 //   1. Redistributions of source code must retain the above
  10 //      copyright notice, this list of conditions and the following
  11 //      disclaimer.
  12 //
  13 //   2. Redistributions in binary form must reproduce the above
  14 //      copyright notice, this list of conditions and the following
  15 //      disclaimer in the documentation and/or other materials
  16 //      provided with the distribution.
  17 //
  18 // THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
  19 // OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
  20 // WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  21 // PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
  22 // CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  23 // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  24 // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
  25 // USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
  26 // AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  27 // LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
  28 // ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  29 // POSSIBILITY OF SUCH DAMAGE.
  30 //
  31 // The views and conclusions contained in the software and
  32 // documentation are those of the authors and should not be
  33 // interpreted as representing official policies, either expressed
  34 // or implied, of GRNET S.A.
  35 // </copyright>
  36 // -----------------------------------------------------------------------
  37
  38 using System.Collections.Concurrent;
  39 using System.Threading;
  40 using System.Threading.Tasks;
  41
  42 namespace Pithos.Core
  43 {
  44     using System;
  45     using System.Collections.Generic;
  46     using System.Linq;
  47     using System.Text;
  48
  49     /// <summary>
  50     /// TODO: Update summary.
  51     /// </summary>
  52     public class JobQueue
  53     {
  54         private readonly BlockingCollection<Action> _statusUpdateQueue = new BlockingCollection<Action>();
  55         private CancellationToken _cancellationToken;
  56
  57
  58         public void Start(CancellationToken token)
  59         {
  60             _cancellationToken = token;
  61             Task.Factory.StartNew(ProcessUpdates, _cancellationToken);
  62         }
  63
  64         private void ProcessUpdates()
  65         {
  66             foreach (var action in _statusUpdateQueue.GetConsumingEnumerable())
  67             {
  68                 action();
  69             }
  70         }
  71
  72         public void Add(Action action)
  73         {
  74             _statusUpdateQueue.Add(action);
  75         }
  76
  77         public void Stop()
  78         {
  79             _statusUpdateQueue.CompleteAdding();
  80         }
  81
  82     }
  83
  84     public class JobAgent:Agent<Action>
  85     {
  86         protected JobAgent(Action<Agent<Action>>  action)
  87             :base(action)
  88         {
  89
  90         }
  91
  92         public static JobAgent Create()
  93         {
  94             return (JobAgent)Start(queue =>
  95             {
  96                 Action loop = null;
  97                 loop = () =>
  98                 {
  99                     var job = queue.Receive();
 100                     job.ContinueWith(t =>
 101                     {
 102                         t.IgnoreExceptions();
 103                         var action = job.Result;
 104                         action();
 105                         queue.DoAsync(loop);
 106                     });
 107                 };
 108                 loop();
 109             });
 110         }
 111
 112     }
 113 }