Statistics
| Branch: | Revision:

root / trunk / Pithos.Core / JobQueue.cs @ b9f5b594

History | View | Annotate | Download (3.5 kB)

1
// -----------------------------------------------------------------------
2
// <copyright file="JobQueue.cs" company="GRNet">
3
// Copyright 2011 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
}