1 // -----------------------------------------------------------------------
2 // <copyright file="JobQueue.cs" company="GRNet">
3 // Copyright 2011 GRNET S.A. All rights reserved.
5 // Redistribution and use in source and binary forms, with or
6 // without modification, are permitted provided that the following
9 // 1. Redistributions of source code must retain the above
10 // copyright notice, this list of conditions and the following
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.
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.
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.
36 // -----------------------------------------------------------------------
38 using System.Collections.Concurrent;
39 using System.Threading;
40 using System.Threading.Tasks;
45 using System.Collections.Generic;
50 /// TODO: Update summary.
54 private readonly BlockingCollection<Action> _statusUpdateQueue = new BlockingCollection<Action>();
55 private CancellationToken _cancellationToken;
58 public void Start(CancellationToken token)
60 _cancellationToken = token;
61 Task.Factory.StartNew(ProcessUpdates, _cancellationToken);
64 private void ProcessUpdates()
66 foreach (var action in _statusUpdateQueue.GetConsumingEnumerable())
72 public void Add(Action action)
74 _statusUpdateQueue.Add(action);
79 _statusUpdateQueue.CompleteAdding();
84 public class JobAgent:Agent<Action>
86 protected JobAgent(Action<Agent<Action>> action)
92 public static JobAgent Create()
94 return (JobAgent)Start(queue =>
99 var job = queue.Receive();
100 job.ContinueWith(t =>
102 t.IgnoreExceptions();
103 var action = job.Result;