##// END OF EJS Templates
implab » ImplabNet
RSS
refactoring, added WorkerPool
cin -
r12:eb418ba8275b promises
parent child
Show More
Show file before | Show file after | Hide comments
@@ -0,0 +1,10
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5
6 namespace Implab {
7 public interface ICancellable {
8 bool Cancel();
9 }
10 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,18
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5
6 namespace Implab {
7 public interface IProgressHandler {
8 string Message {
9 get;
10 set;
11 }
12 float CurrentProgress {
13 get;
14 set;
15 }
16 void InitProgress(float current, float max, string message);
17 }
18 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,14
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5
6 namespace Implab
7 {
8 public interface IProgressNotifier
9 {
10 event EventHandler<ValueEventArgs<string>> MessageUpdated;
11 event EventHandler<ValueEventArgs<float>> ProgressUpdated;
12 EventHandler<ProgressInitEventArgs> ProgressInit;
13 }
14 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,12
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5
6 namespace Implab {
7 public interface ITaskController: IProgressHandler {
8 bool Cancelled {
9 get;
10 }
11 }
12 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,11
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5
6 namespace Implab {
7
8 public class ManagedPromise<T>: Promise<T>, ITaskController, IProgressNotifier {
9
10 }
11 }
Show file before | Show file after | Hide comments
@@ -0,0 +1,131
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Threading;
6 using System.Diagnostics;
7
8 namespace Implab.Parallels {
9 public class WorkerPool : IDisposable {
10 readonly int m_minThreads;
11 readonly int m_maxThreads;
12 int m_runningThreads;
13 object m_lock = new object();
14
15 bool m_disposed = false;
16 ManualResetEvent m_hasTasks = new ManualResetEvent(false);
17 Queue<Action> m_queue = new Queue<Action>();
18
19 public WorkerPool(int min, int max) {
20 if (min < 0)
21 throw new ArgumentOutOfRangeException("min");
22 if (min > max)
23 min = max;
24 m_minThreads = min;
25 m_maxThreads = max;
26
27 for (int i = 0; i < m_minThreads; i++)
28 StartWorker();
29 }
30
31 public Promise<T> Invoke<T>(Func<T> task) {
32 if (m_disposed)
33 throw new ObjectDisposedException(ToString());
34 if (task == null)
35 throw new ArgumentNullException("task");
36
37 var promise = new Promise<T>();
38
39
40
41 return promise;
42 }
43
44 bool StartWorker() {
45 var current = m_runningThreads;
46 // use spins to allocate slot for the new thread
47 do {
48 if (current >= m_maxThreads)
49 // no more slots left
50 return false;
51 } while (current != Interlocked.CompareExchange(ref m_runningThreads, current + 1, current));
52
53 // slot successfully allocated
54
55 var worker = new Thread(this.Worker);
56 worker.Start();
57
58 return true;
59 }
60
61 void EnqueueTask(Action task) {
62 Debug.Assert(task != null);
63 lock (m_queue) {
64 m_queue.Enqueue(task);
65 m_hasTasks.Set();
66 }
67 }
68
69 bool FetchTask(out Action task) {
70 task = null;
71
72 while (true) {
73
74 m_hasTasks.WaitOne();
75
76 if (m_disposed)
77 return false;
78
79 lock (m_queue) {
80 if (m_queue.Count > 0) {
81 task = m_queue.Dequeue();
82 return true;
83 }
84
85 // no tasks left
86 // signal that no more tasks left, lock ensures that this event won't suppress newly added task
87 m_hasTasks.Reset();
88 }
89
90 bool exit = true;
91
92 var current = m_runningThreads;
93 do {
94 if (current <= m_minThreads) {
95 exit = false; // this thread should return and wait for the new events
96 break;
97 }
98 } while (current != Interlocked.CompareExchange(ref m_runningThreads, current - 1, current));
99
100 if (exit)
101 return false;
102 }
103 }
104
105 void Worker() {
106 Action task;
107 while (FetchTask(out task))
108 task();
109 }
110
111 protected virtual void Dispose(bool disposing) {
112 if (disposing) {
113 lock (m_lock) {
114 if (m_disposed)
115 return;
116 m_disposed = true;
117 }
118 m_hasTasks.Set();
119 GC.SuppressFinalize(this);
120 }
121 }
122
123 public void Dispose() {
124 Dispose(true);
125 }
126
127 ~WorkerPool() {
128 Dispose(false);
129 }
130 }
131 }
Show file before | Show file after | Hide comments
1 NO CONTENT: modified file, binary diff hidden
NO CONTENT: modified file, binary diff hidden
Show file before | Show file after | Hide comments
@@ -1,39 +1,33
1 using System;
1 using System;
2 using System.Collections.Generic;
2 using System.Collections.Generic;
3 using System.Linq;
3 using System.Linq;
4 using System.Text;
4 using System.Text;
5
5
6 namespace Implab
6 namespace Implab
7 {
7 {
8 public interface IPromise
8 public interface IPromise: ICancellable
9 {
9 {
10 /// <summary>
10 /// <summary>
11 /// Check whereather the promise has no more than one dependent promise.
11 /// Check whereather the promise has no more than one dependent promise.
12 /// </summary>
12 /// </summary>
13 bool IsExclusive
13 bool IsExclusive
14 {
14 {
15 get;
15 get;
16 }
16 }
17
17
18 /// <summary>
18 /// <summary>
19 /// The current state of the promise.
19 /// The current state of the promise.
20 /// </summary>
20 /// </summary>
21 PromiseState State
21 PromiseState State
22 {
22 {
23 get;
23 get;
24 }
24 }
25
25
26 /// <summary>
26 /// <summary>
27 /// Tries to cancel the the complete chain of promises.
28 /// </summary>
29 /// <returns><c>true</c> - if the promise has been cancelled, otherwise the promise will be resolved (or resolved already).</returns>
30 bool Cancel();
31
32 /// <summary>
33 /// Registers handler for the case when the promise is cencelled. If the promise already cancelled the
27 /// Registers handler for the case when the promise is cencelled. If the promise already cancelled the
34 /// handler will be invoked immediatelly.
28 /// handler will be invoked immediatelly.
35 /// </summary>
29 /// </summary>
36 /// <param name="handler">The handler</param>
30 /// <param name="handler">The handler</param>
37 void HandleCancelled(Action handler);
31 void HandleCancelled(Action handler);
38 }
32 }
39 }
33 }
Show file before | Show file after | Hide comments
@@ -1,47 +1,53
1 <?xml version="1.0" encoding="utf-8"?>
1 <?xml version="1.0" encoding="utf-8"?>
2 <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
2 <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
3 <PropertyGroup>
3 <PropertyGroup>
4 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
4 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
5 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
5 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
6 <ProductVersion>10.0.0</ProductVersion>
6 <ProductVersion>10.0.0</ProductVersion>
7 <SchemaVersion>2.0</SchemaVersion>
7 <SchemaVersion>2.0</SchemaVersion>
8 <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid>
8 <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid>
9 <OutputType>Library</OutputType>
9 <OutputType>Library</OutputType>
10 <RootNamespace>Implab</RootNamespace>
10 <RootNamespace>Implab</RootNamespace>
11 <AssemblyName>Implab</AssemblyName>
11 <AssemblyName>Implab</AssemblyName>
12 </PropertyGroup>
12 </PropertyGroup>
13 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
13 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
14 <DebugSymbols>true</DebugSymbols>
14 <DebugSymbols>true</DebugSymbols>
15 <DebugType>full</DebugType>
15 <DebugType>full</DebugType>
16 <Optimize>false</Optimize>
16 <Optimize>false</Optimize>
17 <OutputPath>bin\Debug</OutputPath>
17 <OutputPath>bin\Debug</OutputPath>
18 <DefineConstants>DEBUG;</DefineConstants>
18 <DefineConstants>DEBUG;</DefineConstants>
19 <ErrorReport>prompt</ErrorReport>
19 <ErrorReport>prompt</ErrorReport>
20 <WarningLevel>4</WarningLevel>
20 <WarningLevel>4</WarningLevel>
21 <ConsolePause>false</ConsolePause>
21 <ConsolePause>false</ConsolePause>
22 </PropertyGroup>
22 </PropertyGroup>
23 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
23 <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
24 <DebugType>full</DebugType>
24 <DebugType>full</DebugType>
25 <Optimize>true</Optimize>
25 <Optimize>true</Optimize>
26 <OutputPath>bin\Release</OutputPath>
26 <OutputPath>bin\Release</OutputPath>
27 <ErrorReport>prompt</ErrorReport>
27 <ErrorReport>prompt</ErrorReport>
28 <WarningLevel>4</WarningLevel>
28 <WarningLevel>4</WarningLevel>
29 <ConsolePause>false</ConsolePause>
29 <ConsolePause>false</ConsolePause>
30 </PropertyGroup>
30 </PropertyGroup>
31 <ItemGroup>
31 <ItemGroup>
32 <Reference Include="System" />
32 <Reference Include="System" />
33 </ItemGroup>
33 </ItemGroup>
34 <ItemGroup>
34 <ItemGroup>
35 <Compile Include="ICancellable.cs" />
36 <Compile Include="IProgressHandler.cs" />
37 <Compile Include="IProgressNotifier.cs" />
35 <Compile Include="IPromise.cs" />
38 <Compile Include="IPromise.cs" />
39 <Compile Include="ITaskController.cs" />
40 <Compile Include="ManagedPromise.cs" />
41 <Compile Include="Parallels\WorkerPool.cs" />
36 <Compile Include="PromiseState.cs" />
42 <Compile Include="PromiseState.cs" />
37 <Compile Include="TaskController.cs" />
43 <Compile Include="TaskController.cs" />
38 <Compile Include="ProgressInitEventArgs.cs" />
44 <Compile Include="ProgressInitEventArgs.cs" />
39 <Compile Include="Properties\AssemblyInfo.cs" />
45 <Compile Include="Properties\AssemblyInfo.cs" />
40 <Compile Include="Promise.cs" />
46 <Compile Include="Promise.cs" />
41 <Compile Include="Parallels\AsyncPool.cs" />
47 <Compile Include="Parallels\AsyncPool.cs" />
42 <Compile Include="Safe.cs" />
48 <Compile Include="Safe.cs" />
43 <Compile Include="ValueEventArgs.cs" />
49 <Compile Include="ValueEventArgs.cs" />
44 </ItemGroup>
50 </ItemGroup>
45 <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
51 <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
46 <ItemGroup />
52 <ItemGroup />
47 </Project> No newline at end of file
53 </Project>
Show file before | Show file after | Hide comments
@@ -1,36 +1,36
1 using System;
1 using System;
2 using System.Collections.Generic;
2 using System.Collections.Generic;
3 using System.Linq;
3 using System.Linq;
4 using System.Text;
4 using System.Text;
5
5
6 namespace Implab
6 namespace Implab
7 {
7 {
8
8 [Serializable]
9 public class ProgressInitEventArgs: EventArgs
9 public class ProgressInitEventArgs: EventArgs
10 {
10 {
11 public float MaxProgress
11 public float MaxProgress
12 {
12 {
13 get;
13 get;
14 private set;
14 private set;
15 }
15 }
16
16
17 public float CurrentProgress
17 public float CurrentProgress
18 {
18 {
19 get;
19 get;
20 private set;
20 private set;
21 }
21 }
22
22
23 public string Message
23 public string Message
24 {
24 {
25 get;
25 get;
26 private set;
26 private set;
27 }
27 }
28
28
29 public ProgressInitEventArgs(float current, float max, string message)
29 public ProgressInitEventArgs(float current, float max, string message)
30 {
30 {
31 this.MaxProgress = max;
31 this.MaxProgress = max;
32 this.CurrentProgress = current;
32 this.CurrentProgress = current;
33 this.Message = message;
33 this.Message = message;
34 }
34 }
35 }
35 }
36 }
36 }
Show file before | Show file after | Hide comments
@@ -1,112 +1,132
1 using System;
1 using System;
2 using System.Collections.Generic;
2 using System.Collections.Generic;
3 using System.Linq;
3 using System.Linq;
4 using System.Text;
4 using System.Text;
5 using System.Threading;
5 using System.Threading;
6
6
7 namespace Implab
7 namespace Implab
8 {
8 {
9 /// <summary>
9 /// <summary>
10 /// This class allows to interact with asyncronuos task.
10 /// This class allows to interact with asyncronuos task.
11 /// </summary>
11 /// </summary>
12 /// <remarks>
12 /// <remarks>
13 /// Members of this object are thread safe.
13 /// Members of this object are thread safe.
14 /// </remarks>
14 /// </remarks>
15 class TaskController
15 class TaskController: IProgressNotifier, ITaskController, ICancellable
16 {
16 {
17 readonly object m_lock;
17 readonly object m_lock;
18 string m_message;
18 string m_message;
19
19
20 float m_current;
20 float m_current;
21 float m_max;
21 float m_max;
22
22
23 bool m_cancelled;
24
23 public event EventHandler<ValueEventArgs<string>> MessageUpdated;
25 public event EventHandler<ValueEventArgs<string>> MessageUpdated;
24 public event EventHandler<ValueEventArgs<float>> ProgressUpdated;
26 public event EventHandler<ValueEventArgs<float>> ProgressUpdated;
25 public event EventHandler<ProgressInitEventArgs> ProgressInit;
27 public event EventHandler<ProgressInitEventArgs> ProgressInit;
26
28
27 public TaskController()
29 public TaskController()
28 {
30 {
29 m_lock = new Object();
31 m_lock = new Object();
30 }
32 }
31
33
32 public string Message
34 public string Message
33 {
35 {
34 get
36 get
35 {
37 {
36 lock (m_lock)
38 lock (m_lock)
37 return m_message;
39 return m_message;
38 }
40 }
39 set
41 set
40 {
42 {
41 lock (m_lock)
43 lock (m_lock)
42 {
44 {
43 m_message = value;
45 m_message = value;
44 OnMessageUpdated();
46 OnMessageUpdated();
45 }
47 }
46 }
48 }
47 }
49 }
48
50
49 public float CurrentProgress
51 public float CurrentProgress
50 {
52 {
51 get
53 get
52 {
54 {
53 lock (m_lock)
55 lock (m_lock)
54 return m_current;
56 return m_current;
55 }
57 }
56 set
58 set
57 {
59 {
58 lock (m_lock)
60 lock (m_lock)
59 {
61 {
60 var prev = m_current;
62 var prev = m_current;
61 m_current = value;
63 m_current = value;
62 if (m_current >= m_max)
64 if (m_current >= m_max)
63 m_current = m_max;
65 m_current = m_max;
64 if (m_current != prev)
66 if (m_current != prev)
65 OnProgressUpdated();
67 OnProgressUpdated();
66 }
68 }
67 }
69 }
68 }
70 }
69
71
70 public void InitProgress(float current, float max, string message)
72 public void InitProgress(float current, float max, string message)
71 {
73 {
72 if (max < 0)
74 if (max < 0)
73 throw new ArgumentOutOfRangeException("max");
75 throw new ArgumentOutOfRangeException("max");
74 if (current < 0 || current > max)
76 if (current < 0 || current > max)
75 throw new ArgumentOutOfRangeException("current");
77 throw new ArgumentOutOfRangeException("current");
76
78
77 lock(m_lock) {
79 lock(m_lock) {
78 m_current = current;
80 m_current = current;
79 m_max = max;
81 m_max = max;
80 m_message = message;
82 m_message = message;
81 OnProgressInit();
83 OnProgressInit();
82 }
84 }
83 }
85 }
84
86
87 public bool Cancelled {
88 get {
89 lock (m_lock)
90 return m_cancelled;
91 }
92 }
93
94 public bool Cancel() {
95 lock (m_lock) {
96 if (!m_cancelled) {
97 m_cancelled = true;
98 return true;
99 } else {
100 return false;
101 }
102 }
103 }
104
85 protected virtual void OnMessageUpdated()
105 protected virtual void OnMessageUpdated()
86 {
106 {
87 var temp = MessageUpdated;
107 var temp = MessageUpdated;
88 if (temp != null)
108 if (temp != null)
89 {
109 {
90 temp(this, new ValueEventArgs<string>(m_message));
110 temp(this, new ValueEventArgs<string>(m_message));
91 }
111 }
92 }
112 }
93
113
94 protected virtual void OnProgressUpdated()
114 protected virtual void OnProgressUpdated()
95 {
115 {
96 var temp = ProgressUpdated;
116 var temp = ProgressUpdated;
97 if (temp != null)
117 if (temp != null)
98 {
118 {
99 temp(this,new ValueEventArgs<float>(m_current));
119 temp(this,new ValueEventArgs<float>(m_current));
100 }
120 }
101 }
121 }
102
122
103 protected virtual void OnProgressInit()
123 protected virtual void OnProgressInit()
104 {
124 {
105 var temp = ProgressInit;
125 var temp = ProgressInit;
106 if (temp != null)
126 if (temp != null)
107 {
127 {
108 temp(this, new ProgressInitEventArgs(m_current,m_max, m_message));
128 temp(this, new ProgressInitEventArgs(m_current,m_max, m_message));
109 }
129 }
110 }
130 }
111 }
131 }
112 }
132 }
Show file before | Show file after | Hide comments
@@ -1,20 +1,21
1 using System;
1 using System;
2 using System.Collections.Generic;
2 using System.Collections.Generic;
3 using System.Linq;
3 using System.Linq;
4 using System.Text;
4 using System.Text;
5
5
6 namespace Implab
6 namespace Implab
7 {
7 {
8 [Serializable]
8 public class ValueEventArgs<T>: EventArgs
9 public class ValueEventArgs<T>: EventArgs
9 {
10 {
10 public ValueEventArgs(T value)
11 public ValueEventArgs(T value)
11 {
12 {
12 this.Value = value;
13 this.Value = value;
13 }
14 }
14 public T Value
15 public T Value
15 {
16 {
16 get;
17 get;
17 private set;
18 private set;
18 }
19 }
19 }
20 }
20 }
21 }
General Comments 0
You need to be logged in to leave comments. Login now