Mercurial > pub > ImplabNet

annotate MonoPlay/Program.cs @ 123:f4d6ea6969cc v2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
async queue improvements
author cin
date Tue, 13 Jan 2015 01:42:38 +0300
parents 0c8685c8b56b
children a336cb13c6a9
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
93
dc4942d09e74 improved tracing
cin
parents:
diff changeset
1 using System;
dc4942d09e74 improved tracing
cin
parents:
diff changeset
2 using Implab.Diagnostics;
dc4942d09e74 improved tracing
cin
parents:
diff changeset
3 using Implab.Parallels;
dc4942d09e74 improved tracing
cin
parents:
diff changeset
4 using Implab;
103
cin
parents: 94
diff changeset
5 using System.Collections.Generic;
cin
parents: 94
diff changeset
6 using System.Collections.Concurrent;
93
dc4942d09e74 improved tracing
cin
parents:
diff changeset
7
dc4942d09e74 improved tracing
cin
parents:
diff changeset
8 namespace MonoPlay {
dc4942d09e74 improved tracing
cin
parents:
diff changeset
9 class MainClass {
dc4942d09e74 improved tracing
cin
parents:
diff changeset
10 public static void Main(string[] args) {
94
a43745f81f10 minor fixes
cin
parents: 93
diff changeset
11 if (args == null)
a43745f81f10 minor fixes
cin
parents: 93
diff changeset
12 throw new ArgumentNullException("args");
a43745f81f10 minor fixes
cin
parents: 93
diff changeset
13
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
14 var q1 = new AsyncQueue<int>();
104
5f10d54b45df renamed Promise.Last -> Promise.On
cin
parents: 103
diff changeset
15 var q2 = new Queue<int>();
103
cin
parents: 94
diff changeset
16
cin
parents: 94
diff changeset
17 const int count = 10000000;
cin
parents: 94
diff changeset
18
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
19 int res1 = 0, res2 = 0;
103
cin
parents: 94
diff changeset
20 var t1 = Environment.TickCount;
93
dc4942d09e74 improved tracing
cin
parents:
diff changeset
21
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
22 AsyncPool.RunThread(
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
23 () => {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
24 for (var i = 0; i < count; i++)
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
25 q1.Enqueue(1);
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
26 Console.WriteLine("done writer #1: {0} ms", Environment.TickCount - t1);
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
27 },
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
28 () => {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
29 for (var i = 0; i < count; i++)
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
30 q1.Enqueue(2);
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
31 Console.WriteLine("done writer #2: {0} ms", Environment.TickCount - t1);
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
32 },
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
33 () => {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
34 int temp = 0;
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
35 int i = 0;
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
36 while (i < count)
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
37 if (q1.TryDequeue(out temp)) {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
38 i++;
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
39 res1 += temp;
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
40 }
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
41 Console.WriteLine("done reader #1: {0} ms", Environment.TickCount - t1);
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
42 },
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
43 () => {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
44 int temp = 0;
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
45 int i = 0;
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
46 while (i < count)
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
47 if (q1.TryDequeue(out temp)) {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
48 i++;
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
49 res2 += temp;
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
50 }
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
51 Console.WriteLine("done reader #2: {0} ms", Environment.TickCount - t1);
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
52 }
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
53 )
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
54 .Combine()
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
55 .Join();
93
dc4942d09e74 improved tracing
cin
parents:
diff changeset
56
122
0c8685c8b56b minor fixes and improvements of AsyncQueue, additional tests
cin
parents: 121
diff changeset
57 Console.WriteLine("done: {0} ms, summ#1: {1}, summ#2: {2}, total: {3}, count: {4}", Environment.TickCount - t1, res1, res2, res1 + res2, count*2);
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
58
103
cin
parents: 94
diff changeset
59 var t2 = Environment.TickCount;
cin
parents: 94
diff changeset
60 Console.WriteLine("MTQueue: {0} ms", t2 - t1);
cin
parents: 94
diff changeset
61
cin
parents: 94
diff changeset
62 t1 = Environment.TickCount;
93
dc4942d09e74 improved tracing
cin
parents:
diff changeset
63
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
64 for (var i = 0; i < count * 2; i++)
103
cin
parents: 94
diff changeset
65 q2.Enqueue(i);
cin
parents: 94
diff changeset
66
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
67 for (var i = 0; i < count * 2; i++)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
68 q2.Dequeue();
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
69
103
cin
parents: 94
diff changeset
70 t2 = Environment.TickCount;
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
71 Console.WriteLine("Queue: {0} ms", t2 - t1);
103
cin
parents: 94
diff changeset
72
104
5f10d54b45df renamed Promise.Last -> Promise.On
cin
parents: 103
diff changeset
73 q2 = new Queue<int>();
93
dc4942d09e74 improved tracing
cin
parents:
diff changeset
74
103
cin
parents: 94
diff changeset
75 t1 = Environment.TickCount;
cin
parents: 94
diff changeset
76
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
77
121
62d2f1e98c4e working version of AsyncQueue and batch operations
cin
parents: 120
diff changeset
78 AsyncPool.RunThread(
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
79 () => {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
80 for (var i = 0; i < count; i++)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
81 lock (q2)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
82 q2.Enqueue(i);
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
83 },
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
84 () => {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
85 for (var i = 0; i < count; i++)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
86 lock (q2)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
87 q2.Enqueue(i);
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
88 },
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
89 () => {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
90 for (int i = 0; i < count ;)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
91 lock (q2) {
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
92 if (q2.Count == 0)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
93 continue;
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
94 q2.Dequeue();
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
95 i++;
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
96 }
108
cin
parents: 104
diff changeset
97
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
98 },
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
99 () => {
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
100 for (int i = 0; i < count ;)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
101 lock (q2) {
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
102 if (q2.Count == 0)
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
103 continue;
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
104 q2.Dequeue();
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
105 i++;
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
106 }
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
107
120
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
108 }
f1b897999260 improved asyncpool usability
cin
parents: 119
diff changeset
109 )
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
110 .Combine()
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
111 .Join();
108
cin
parents: 104
diff changeset
112
cin
parents: 104
diff changeset
113
103
cin
parents: 94
diff changeset
114
cin
parents: 94
diff changeset
115 t2 = Environment.TickCount;
119
2573b562e328 Promises rewritten, added improved version of AsyncQueue
cin
parents: 108
diff changeset
116 Console.WriteLine("Queue+Lock: {0} ms", t2 - t1);
93
dc4942d09e74 improved tracing
cin
parents:
diff changeset
117
dc4942d09e74 improved tracing
cin
parents:
diff changeset
118 }
dc4942d09e74 improved tracing
cin
parents:
diff changeset
119 }
dc4942d09e74 improved tracing
cin
parents:
diff changeset
120 }