Mercurial > pub > ImplabNet

annotate Implab/Safe.cs @ 129:471f596b2603 v2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Added SharedLock to synchronization routines
author cin
date Thu, 29 Jan 2015 18:31:06 +0300
parents 6241bff0cd64
children b5c2d609d71b
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
1
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
1 using System;
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
2 using System.Collections.Generic;
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
3 using System.Linq;
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
4 using System.Text;
51
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
5 using System.Text.RegularExpressions;
66
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
6 using System.Diagnostics;
1
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
7
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
8 namespace Implab
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
9 {
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
10 public static class Safe
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
11 {
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
12 public static void ArgumentMatch(string value, string paramName, Regex rx) {
51
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
13 if (rx == null)
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
14 throw new ArgumentNullException("rx");
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
15 if (!rx.IsMatch(value))
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
16 throw new ArgumentException(String.Format("The prameter value must match {0}", rx), paramName);
51
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
17 }
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
18
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
19 public static void ArgumentNotEmpty(string value, string paramName) {
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
20 if (String.IsNullOrEmpty(value))
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
21 throw new ArgumentException("The parameter can't be empty", paramName);
90
efcb076407a7 code cleanup
cin
parents: 66
diff changeset
22 }
efcb076407a7 code cleanup
cin
parents: 66
diff changeset
23
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
24 public static void ArgumentNotEmpty<T>(T[] value, string paramName) {
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
25 if (value == null || value.Length == 0)
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
26 throw new ArgumentException("The array must be not emty", paramName);
51
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
27 }
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
28
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
29 public static void ArgumentNotNull(object value, string paramName) {
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
30 if (value == null)
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
31 throw new ArgumentNullException(paramName);
51
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
32 }
2c332a9c64c0 Added methods for parameter checks
cin
parents: 31
diff changeset
33
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
34 public static void ArgumentInRange(int value, int min, int max, string paramName) {
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
35 if (value < min || value > max)
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 119
diff changeset
36 throw new ArgumentOutOfRangeException(paramName);
55
c0bf853aa04f Added initial JSON support
cin
parents: 51
diff changeset
37 }
c0bf853aa04f Added initial JSON support
cin
parents: 51
diff changeset
38
128
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
39 public static void Dispose(params IDisposable[] objects) {
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
40 foreach (var d in objects)
126
f7b2b8bfbb8c minor changes
cin
parents: 121
diff changeset
41 if (d != null)
f7b2b8bfbb8c minor changes
cin
parents: 121
diff changeset
42 d.Dispose();
1
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
43 }
66
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
44
128
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
45 public static void Dispose(params object[] objects) {
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
46 foreach (var obj in objects) {
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
47 var d = obj as IDisposable;
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
48 if (d != null)
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
49 d.Dispose();
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
50 }
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
51 }
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
52
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
53 public static void Dispose(object obj) {
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
54 var d = obj as IDisposable;
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
55 if (d != null)
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
56 d.Dispose();
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
57 }
6241bff0cd64 Added Signal class a lightweight alternative to ManualResetEvent
cin
parents: 126
diff changeset
58
66
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
59 [DebuggerStepThrough]
94
a43745f81f10 minor fixes
cin
parents: 90
diff changeset
60 public static IPromise<T> InvokePromise<T>(Func<T> action) {
66
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
61 ArgumentNotNull(action, "action");
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
62
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
63 var p = new Promise<T>();
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
64 try {
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
65 p.Resolve(action());
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
66 } catch (Exception err) {
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
67 p.Reject(err);
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
68 }
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
69
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
70 return p;
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
71 }
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
72
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
73 [DebuggerStepThrough]
96
daffa72a1cec Added the chaining method to the non-generic IPromise
cin
parents: 95
diff changeset
74 public static IPromise InvokePromise(Action action) {
95
0141a165d032 minor changes
cin
parents: 94
diff changeset
75 ArgumentNotNull(action, "action");
0141a165d032 minor changes
cin
parents: 94
diff changeset
76
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 96
diff changeset
77 var p = new Promise();
95
0141a165d032 minor changes
cin
parents: 94
diff changeset
78 try {
0141a165d032 minor changes
cin
parents: 94
diff changeset
79 action();
0141a165d032 minor changes
cin
parents: 94
diff changeset
80 p.Resolve();
0141a165d032 minor changes
cin
parents: 94
diff changeset
81 } catch (Exception err) {
0141a165d032 minor changes
cin
parents: 94
diff changeset
82 p.Reject(err);
0141a165d032 minor changes
cin
parents: 94
diff changeset
83 }
0141a165d032 minor changes
cin
parents: 94
diff changeset
84
0141a165d032 minor changes
cin
parents: 94
diff changeset
85 return p;
0141a165d032 minor changes
cin
parents: 94
diff changeset
86 }
0141a165d032 minor changes
cin
parents: 94
diff changeset
87
0141a165d032 minor changes
cin
parents: 94
diff changeset
88 [DebuggerStepThrough]
94
a43745f81f10 minor fixes
cin
parents: 90
diff changeset
89 public static IPromise<T> InvokePromise<T>(Func<IPromise<T>> action) {
66
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
90 ArgumentNotNull(action, "action");
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
91
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
92 try {
94
a43745f81f10 minor fixes
cin
parents: 90
diff changeset
93 return action() ?? Promise<T>.ExceptionToPromise(new Exception("The action returned null"));
66
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
94 } catch (Exception err) {
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
95 return Promise<T>.ExceptionToPromise(err);
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
96 }
790e8a997d30 Refactoring
cin
parents: 55
diff changeset
97 }
1
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
98 }
6fb3b01ee971 Added utility class for safe disposing methods.
cin
parents:
diff changeset
99 }