| @@ -0,0 +1,40 | |||
|
|
1 | using Implab.Parallels; | |
|
|
2 | using System; | |
|
|
3 | using System.Collections.Generic; | |
|
|
4 | using System.Linq; | |
|
|
5 | using System.Text; | |
|
|
6 | using System.Threading; | |
|
|
7 | ||
|
|
8 | namespace Implab { | |
|
|
9 | public class SafePool<T> where T : new() { | |
|
|
10 | readonly MTQueue<T> m_queue = new MTQueue<T>(); | |
|
|
11 | readonly int m_size; | |
|
|
12 | int m_count = 0; | |
|
|
13 | ||
|
|
14 | public SafePool() : this(10) { | |
|
|
15 | ||
|
|
16 | } | |
|
|
17 | ||
|
|
18 | public SafePool(int size) { | |
|
|
19 | Safe.ArgumentInRange(size,1,size,"size"); | |
|
|
20 | ||
|
|
21 | m_size = size; | |
|
|
22 | } | |
|
|
23 | ||
|
|
24 | public T Allocate() { | |
|
|
25 | T instance; | |
|
|
26 | if (m_queue.TryDequeue(out instance)) { | |
|
|
27 | Interlocked.Decrement(ref m_count); | |
|
|
28 | return instance; | |
|
|
29 | } | |
|
|
30 | return new T(); | |
|
|
31 | } | |
|
|
32 | ||
|
|
33 | public void Release(T instance) { | |
|
|
34 | if (m_count < m_size) { | |
|
|
35 | Interlocked.Increment(ref m_count); | |
|
|
36 | m_queue.Enqueue(instance); | |
|
|
37 | } | |
|
|
38 | } | |
|
|
39 | } | |
|
|
40 | } | |
| @@ -92,6 +92,7 | |||
|
|
92 | 92 | <Compile Include="Parsing\StarToken.cs" /> |
|
|
93 | 93 | <Compile Include="Parsing\SymbolToken.cs" /> |
|
|
94 | 94 | <Compile Include="Parsing\Token.cs" /> |
|
|
95 | <Compile Include="SafePool.cs" /> | |
|
|
95 | 96 | <Compile Include="ServiceLocator.cs" /> |
|
|
96 | 97 | <Compile Include="TaskController.cs" /> |
|
|
97 | 98 | <Compile Include="ProgressInitEventArgs.cs" /> |
General Comments 0
You need to be logged in to leave comments.
Login now