concurrent_pipeline2.flx

fun ack(x:int,y:int):int =>
  if x == 0 then y + 1
  elif y == 0 then ack(x - 1, 1)
  else ack(x - 1, ack(x, y - 1))
  endif
;

fun slow (x:int)  {
  //println$ "Slow " + x.str;
  assert ack(3,5) > 0;
  return 1;
}

proc  countem (y:int) {
  //println$ "Got one";
}

proc check(concurrent:bool)
{
  async_run {
    if concurrent do
      spawn_process {; };
/*
      spawn_process {; };
      spawn_process {; };
      spawn_process {; };
      spawn_process {; };
      spawn_process {; };
      spawn_process {; };
*/
    done
    for(var i = 1; i<1000; ++i;) {
//if i%100 == 0 perform
//println$ "i=" + i.str;
      #(source_from_list ([1,2,3,4,5,6,7,8]) |->
      function slow |-> 
      function slow |-> 
      function slow |-> 
      function slow |-> 
      function slow |-> 
      function slow |-> 
      function slow |-> 
      function slow |-> 
      procedure countem);
    };
  };
}

var start = time();
check(false);
var elapsed = time() - start;
println$ "Serial     Elapsed " + elapsed.str;


start = time();
check(true);
elapsed = time() - start;
println$ "Concurrent Elapsed " + elapsed.str;