Mercurial > pub > ImplabNet
annotate MonoPlay/Program.cs @ 144:8c0b95069066 v2
DRAFT: refactoring
| author | cin |
|---|---|
| date | Fri, 06 Mar 2015 15:45:26 +0300 |
| parents | f75cfa58e3d4 |
| children | 706fccb85524 |
| rev | line source |
|---|---|
| 93 | 1 using System; |
| 2 using Implab.Diagnostics; | |
| 3 using Implab.Parallels; | |
| 4 using Implab; | |
| 103 | 5 using System.Collections.Generic; |
| 6 using System.Collections.Concurrent; | |
| 136 | 7 using System.Threading; |
| 93 | 8 |
| 9 namespace MonoPlay { | |
| 10 class MainClass { | |
| 11 public static void Main(string[] args) { | |
| 94 | 12 if (args == null) |
| 13 throw new ArgumentNullException("args"); | |
| 14 | |
| 103 | 15 var t1 = Environment.TickCount; |
| 93 | 16 |
| 136 | 17 const int reads = 100000; |
| 18 const int writes = 1000; | |
| 19 const int readThreads = 8; | |
| 20 const int writeThreads = 0; | |
| 21 | |
| 22 var l = new SharedLock(); | |
| 23 var st = new HashSet<int>(); | |
| 125 | 24 |
| 136 | 25 Action reader1 = () => { |
| 26 for (int i =0; i < reads; i++) { | |
| 27 try { | |
| 28 l.LockShared(); | |
| 29 st.Contains(i % 1000); | |
| 30 Thread.Sleep(0); | |
| 31 } finally { | |
| 32 l.Release(); | |
| 33 } | |
| 34 } | |
| 35 }; | |
| 36 | |
| 37 Action reader2 = () => { | |
| 38 for(var i = 0; i < reads; i++) | |
| 39 lock(st) { | |
| 40 st.Contains(i % 1000); | |
| 41 Thread.Sleep(0); | |
| 42 } | |
| 43 }; | |
| 93 | 44 |
| 136 | 45 Action writer1 = () => { |
| 46 var rnd = new Random(Environment.TickCount); | |
| 47 for (int i = 0; i < writes; i++) { | |
| 48 try { | |
| 49 l.LockExclusive(); | |
| 50 st.Add(rnd.Next(1000)); | |
| 51 //Thread.Sleep(1); | |
| 52 } finally { | |
| 53 l.Release(); | |
| 54 } | |
| 55 } | |
| 56 }; | |
| 125 | 57 |
| 136 | 58 Action writer2 = () => { |
| 59 var rnd = new Random(Environment.TickCount); | |
| 60 for (int i = 0; i < writes; i++) { | |
| 61 lock (st) { | |
| 62 st.Add(rnd.Next(1000)); | |
| 63 //Thread.Sleep(1); | |
| 64 } | |
| 65 } | |
| 66 }; | |
| 67 | |
| 68 | |
| 125 | 69 |
| 136 | 70 var readers = new IPromise[readThreads]; |
| 71 for (int i = 0; i < readThreads; i++) | |
|
138
f75cfa58e3d4
added ICancellable.Cancel(Exception) to allow specify the reason of cancellation
cin
parents:
136
diff
changeset
|
72 readers[i] = AsyncPool.RunThread(reader2); |
| 136 | 73 |
| 74 var writers = new IPromise[writeThreads]; | |
| 75 for (int i = 0; i < writeThreads; i++) | |
| 76 writers[i] = AsyncPool.RunThread(writer1); | |
| 77 | |
| 78 | |
| 79 new [] { | |
| 80 readers.Bundle().On(() => Console.WriteLine("readers complete in {0} ms", Environment.TickCount - t1)), | |
| 81 writers.Bundle().On(() => Console.WriteLine("writers complete in {0} ms", Environment.TickCount - t1)) | |
| 82 }.Bundle().Join(); | |
| 83 | |
| 84 | |
| 121 | 85 |
| 103 | 86 var t2 = Environment.TickCount; |
| 125 | 87 Console.WriteLine("done: {0} ms, {1:.00} Mb, {2} GC", t2 - t1, GC.GetTotalMemory(false) / (1024*1024), GC.CollectionCount(0) ); |
| 93 | 88 |
| 89 } | |
| 136 | 90 |
| 91 | |
| 93 | 92 } |
| 93 } |