app.d

import std.stdio;
import leveldb;
import vibe.core.concurrency;
import vibe.core.core;
import std.datetime;

shared static int counter;
shared static Task dbTask;
struct Query{ Task sender; string msg;}

static void dbFunc(){
  dbTask = Task.getThis();
  while(true){
    receive(
      (Query q){
        core.atomic.atomicOp!"+="(counter, 1) ;
        q.sender.send("result");
      }    
    );
  }
}


static void workerFunc(Task db){
  while(true){
    db.send(Query(Task.getThis(), "test"));    
    receive( (string astring) { 
      //writeln("received string", astring);
      });   
  }
}


shared static this()
{
  
  runWorkerTask({
    setTimer(1.seconds, {
     writeln("counter: ", counter); 
     counter = 0;
     stdout.flush();
     }, true);
    });
    

    runWorkerTask(&dbFunc);
    sleep(1.seconds);
    runWorkerTaskDist(&workerFunc,  dbTask);


}