!7

set flag LeanMode. set flag OurSyncCollections. set flag collectionMutex_simple.
//do not include class Symbol.
set flag SymbolAsString.
//do not include function getOpt.

sbool ping() { ret ping_v3(); }

static new PingSource myPingSource;

static double coresToUse = .5;
static double frequency = 100;
static new BoolVar on;
static volatile long result;
static NotTooOften nto = nto(1.0);

p/*-exp*/ { // exp for "experiment" automatically reloads on updates
  new Schedule<Runnable> schedule;
  //enableScaffolding(schedule);
  schedule.add(0, r {
    dontprint("on");
    myPingSource.action(null);
    on.set();
  });
  schedule.add(coresToUse, r {
    dontprint("off");
    on.unset();
    myPingSource.action(-> {
      temp tempPingPrivileged();
      on.waitUntilTrue();
      true;
    });
  });
  schedule.jumpFromTo(1, 0);
  schedule.speedUp(frequency);
  //printStruct(schedule);
  thread "Counting" {
    temp tempSetPingSource(myPingSource);
    new Timestamp start;
    
    long i = 0;
    var ping = pingSource();
    while (true) {
      if (ping_trueIfSlept(ping)) {
        result = i;
        if (nto!) {
          Seconds cpu = new(nanosToSeconds(currentThreadTotalCPUNanos()));
          Seconds clock = new(elapsedSeconds(start));
          double numbersPerSecond = doubleRatio(i, clock!);
          print("I have counted until " + n2(i) + ". pid=" + pid() + ", cpu time: " + cpu + " (clock: " + clock
            + ", ratio: " + formatDouble1(doublePercentRatio(cpu, clock)) + "%) - "
            + n2(ifloor(numbersPerSecond)) + " numbers per second");
        }
      }
      
      ++i;
    }
  }
  schedule.run();
}