##// END OF EJS Templates
implab » ImplabNet
RSS
Improved AsyncQueue...
Improved AsyncQueue Removed ImplabFx
cin - - Load All Authors

File last commit:

r233:d6fe09f5592c v2
r233:d6fe09f5592c v2
Show More
Program.cs
183 lines | 6.2 KiB | text/x-csharp | CSharpLexer
/ Implab.Playground / Program.cs
History | Source | Raw |Copy content |Copy permalink
cin
JsonXmlReader performance tuning...
 r229 using Implab.Formats.Json;
cin
Improved AsyncQueue...
 r233 using Implab.Parallels;
cin
JsonXmlReader performance tuning...
 r229 using Implab.Xml;
using System;
cin
Improved AsyncQueue...
 r233 using System.Collections.Concurrent;
cin
JsonXmlReader performance tuning...
 r229 using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
cin
Improved AsyncQueue...
 r233 using System.Threading;
cin
JsonXmlReader performance tuning...
 r229 using System.Threading.Tasks;
using System.Xml;
using System.Xml.Serialization;
namespace Implab.Playground {
public class Program {
cin
Improved AsyncQueue...
 r233 static void EnqueueRange<T>(ConcurrentQueue<T> q, T[] data, int offset, int len) {
for (var i = offset; i < offset + len; i++)
q.Enqueue(data[i]);
}
static bool TryDequeueRange<T>(ConcurrentQueue<T> q,T[] buffer,int offset, int len, out int actual) {
actual = 0;
T res;
while(q.TryDequeue(out res)) {
buffer[offset + actual] = res;
actual++;
if (actual == len)
break;
}
return actual != 0;
}
static void EnqueueRange<T>(SimpleAsyncQueue<T> q, T[] data, int offset, int len) {
for (var i = offset; i < offset + len; i++)
q.Enqueue(data[i]);
}
cin
JsonXmlReader performance tuning...
 r229
cin
Improved AsyncQueue...
 r233 static bool TryDequeueRange<T>(SimpleAsyncQueue<T> q, T[] buffer, int offset, int len, out int actual) {
actual = 0;
T res;
while (q.TryDequeue(out res)) {
buffer[offset + actual] = res;
actual++;
if (actual == len)
break;
}
return actual != 0;
}
cin
JsonXmlReader performance tuning...
 r229
cin
Improved AsyncQueue...
 r233 /*
static void EnqueueRange<T>(AsyncQueue<T> q, T[] data, int offset, int len) {
for (var i = offset; i < offset + len; i++)
q.Enqueue(data[i]);
}
cin
JsonXmlReader performance tuning...
 r229
cin
Improved AsyncQueue...
 r233 static bool TryDequeueRange<T>(AsyncQueue<T> q, T[] buffer, int offset, int len, out int actual) {
actual = 0;
T res;
while (q.TryDequeue(out res)) {
buffer[offset + actual] = res;
actual++;
if (actual == len)
break;
}
return actual != 0;
}
*/
static void EnqueueRange<T>(AsyncQueue<T> q, T[] data, int offset, int len) {
q.EnqueueRange(data, offset, len);
cin
JsonXmlReader performance tuning...
 r229 }
cin
Improved AsyncQueue...
 r233 static bool TryDequeueRange<T>(AsyncQueue<T> q, T[] buffer, int offset, int len, out int actual) {
return q.TryDequeueRange(buffer, offset, len, out actual);
}
cin
JsonXmlReader performance tuning...
 r229 static void Main(string[] args) {
cin
Improved AsyncQueue...
 r233 //var queue = new ConcurrentQueue<int>();
var queue = new AsyncQueue<int>();
//var queue = new SimpleAsyncQueue<int>();
const int wBatch = 32;
const long wCount = 1000000;
const long total = wBatch * wCount * 3;
long r1 = 0, r2 = 0, r3 = 0;
const int rBatch = 1000;
long read = 0;
var t1 = Environment.TickCount;
AsyncPool.RunThread(
() => {
var buffer = new int[wBatch];
for (int i = 0; i < wBatch; i++)
buffer[i] = 1;
for (int i = 0; i < wCount; i++)
EnqueueRange(queue, buffer, 0, wBatch);
Console.WriteLine("done writer #1: {0} ms", Environment.TickCount - t1);
},
() => {
var buffer = new int[wBatch];
for (int i = 0; i < wBatch; i++)
buffer[i] = 1;
for (int i = 0; i < wCount; i++)
EnqueueRange(queue, buffer, 0, wBatch);
Console.WriteLine("done writer #2: {0} ms", Environment.TickCount - t1);
},
() => {
var buffer = new int[wBatch];
for (int i = 0; i < wBatch; i++)
buffer[i] = 1;
for (int i = 0; i < wCount; i++)
EnqueueRange(queue, buffer, 0, wBatch);
Console.WriteLine("done writer #3: {0} ms", Environment.TickCount - t1);
},
() => {
var buffer = new int[rBatch];
while (read < total) {
int actual;
if (TryDequeueRange(queue, buffer, 0, rBatch, out actual)) {
for (int i = 0; i < actual; i++)
r1 += buffer[i];
Interlocked.Add(ref read, actual);
}
}
Console.WriteLine("done reader #1: {0} ms", Environment.TickCount - t1);
}/*,
() => {
var buffer = new int[rBatch];
while (read < total) {
int actual;
if (TryDequeueRange(queue, buffer, 0, rBatch, out actual)) {
for (int i = 0; i < actual; i++)
r2 += buffer[i];
Interlocked.Add(ref read, actual);
}
}
Console.WriteLine("done reader #2: {0} ms", Environment.TickCount - t1);
}*//*,
() => {
var buffer = new int[rBatch];
while (read < total) {
int actual;
if (TryDequeueRange(queue, buffer, 0, rBatch, out actual)) {
for (int i = 0; i < actual; i++)
r3 += buffer[i];
Interlocked.Add(ref read, actual);
}
}
Console.WriteLine("done reader #3: {0} ms", Environment.TickCount - t1);
}*/
)
.PromiseAll()
.Join();
Console.WriteLine(
"done: {0} ms, summ#1: {1}, summ#2: {2}, total: {3}, count: {4}",
Environment.TickCount - t1,
r1,
r2,
r1 + r2 + r3,
total
);
cin
JsonXmlReader performance tuning...
 r229
Console.WriteLine("done");
}
}
}