mirror of
https://github.com/xomboverlord/ldc.git
synced 2026-01-13 11:23:14 +01:00
b15b3484c8
Initial commit after moving to Tango instead of Phobos. Lots of bugfixes... This build is not suitable for most things.
45 lines
1.1 KiB
D
45 lines
1.1 KiB
D
/*******************************************************************************
|
|
|
|
|
|
*******************************************************************************/
|
|
|
|
import tango.io.Stdout;
|
|
|
|
import tango.time.StopWatch;
|
|
|
|
import tango.util.log.Configurator;
|
|
|
|
import tango.net.cluster.NetworkQueue;
|
|
|
|
import tango.net.cluster.tina.Cluster;
|
|
|
|
/*******************************************************************************
|
|
|
|
|
|
*******************************************************************************/
|
|
|
|
void main (char[][] args)
|
|
{
|
|
StopWatch w;
|
|
|
|
auto cluster = (new Cluster).join;
|
|
auto queue = new NetworkQueue (cluster, "my.queue.channel");
|
|
|
|
while (true)
|
|
{
|
|
w.start;
|
|
for (int i=10000; i--;)
|
|
queue.put (queue.EmptyMessage);
|
|
|
|
Stdout.formatln ("{} put/s", 10000/w.stop);
|
|
|
|
uint count;
|
|
w.start;
|
|
while (queue.get !is null)
|
|
++count;
|
|
|
|
Stdout.formatln ("{} get/s", count/w.stop);
|
|
}
|
|
}
|
|
|