|
|
using System;
|
|
|
using Implab.Diagnostics;
|
|
|
using Implab.Parallels;
|
|
|
using Implab;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Collections.Concurrent;
|
|
|
|
|
|
namespace MonoPlay {
|
|
|
class MainClass {
|
|
|
public static void Main(string[] args) {
|
|
|
if (args == null)
|
|
|
throw new ArgumentNullException("args");
|
|
|
|
|
|
var q1 = new MTQueue<int>();
|
|
|
var q2 = new Queue<int>();
|
|
|
|
|
|
const int count = 10000000;
|
|
|
|
|
|
|
|
|
var t1 = Environment.TickCount;
|
|
|
|
|
|
Promise<int>.CreateComposite(
|
|
|
new [] {
|
|
|
AsyncPool.InvokeNewThread(() => {
|
|
|
for (var i = 0; i < count; i++)
|
|
|
q1.Enqueue(i);
|
|
|
}),
|
|
|
AsyncPool.InvokeNewThread(() => {
|
|
|
int temp = 0;
|
|
|
for(int i =0 ; i< count ; i++)
|
|
|
while(!q1.TryDequeue(out temp)){
|
|
|
}
|
|
|
})
|
|
|
}
|
|
|
).Join();
|
|
|
|
|
|
var t2 = Environment.TickCount;
|
|
|
Console.WriteLine("MTQueue: {0} ms", t2 - t1);
|
|
|
|
|
|
t1 = Environment.TickCount;
|
|
|
|
|
|
for (var i = 0; i < count; i++)
|
|
|
q2.Enqueue(i);
|
|
|
|
|
|
t2 = Environment.TickCount;
|
|
|
Console.WriteLine("LinkedList: {0} ms", t2 - t1);
|
|
|
|
|
|
q2 = new Queue<int>();
|
|
|
|
|
|
t1 = Environment.TickCount;
|
|
|
|
|
|
Promise<int>.CreateComposite(
|
|
|
new [] {
|
|
|
AsyncPool.InvokeNewThread(() => {
|
|
|
for (var i = 0; i < count; i++)
|
|
|
lock (q2)
|
|
|
q2.Enqueue(i);
|
|
|
}),
|
|
|
AsyncPool.InvokeNewThread(() => {
|
|
|
for(int i = 0 ; i< count ;)
|
|
|
lock(q2) {
|
|
|
if(q2.Count == 0)
|
|
|
continue;
|
|
|
q2.Dequeue();
|
|
|
i++;
|
|
|
}
|
|
|
|
|
|
})
|
|
|
}
|
|
|
).Join();
|
|
|
|
|
|
|
|
|
|
|
|
t2 = Environment.TickCount;
|
|
|
Console.WriteLine("LinkedList+Lock: {0} ms", t2 - t1);
|
|
|
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
