!7

// Now with processor GHz estimate

set flag LeanMode. set flag OurSyncCollections. set flag collectionMutex_simple. set flag SymbolAsString.

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);

sclass Counter {

  new Timestamp start;

  run {

    temp tempSetPingSource(myPingSource);

    loop();

  }

  void loop {

    long i = 0;

    var ping = pingSource();

    while (true) {

      if (ping_trueIfSlept(ping)) {

        result = i;

        if (nto!) printStats();

      }

      ++i;

    }

  }

  void printStats {

    Seconds cpu = new(nanosToSeconds(currentThreadTotalCPUNanos()));

    Seconds clock = new(elapsedSeconds(start));

    double cpuRatio = doubleRatio(cpu, clock);

    double numbersPerSecond = doubleRatio(result, clock!);

    double npsPerCore = doubleRatio(numbersPerSecond, cpuRatio);

    double nsPerNumber = doubleRatio(oneBillion(), npsPerCore);

    double assumedCycles = 2;

    Freq speedEstimate = new(assumedCycles*npsPerCore);

    print("I have counted until " + n2(result) + ". pid=" + pid() + ", cpu time: " + cpu + " (clock: " + clock

      + ", ratio: " + formatDouble1(cpuRatio*100) + "%) - "

      + n2(lfloor(numbersPerSecond)) + " numbers per second = "

      + n2(lfloor(npsPerCore)) + " numbers per second per core = "

      + formatDouble1(nsPerNumber) + " ns per number"

      + " => Processor speed estimate: " + speedEstimate.format1());

  }

}

p {

  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" { new Counter().run(); }

  schedule.run();

}