!7

module ThreadComparison > DynSingleFunction {
  int multiplicity = 4;
  
  void doIt {
    print("Benchmarking...");
    final long endTime = sysTimePlus(5000);
    final L<AtomicLong> counts;
    L<Thread> threads = ll(
      maxPriorityThread(r { while (sysNow() < endTime) incAtomicLong(count1) }),
      minPriorityThread(r { while (sysNow() < endTime) incAtomicLong(count2) }));
    joinThreads(threads);
    print("Count 1 [priority " + first(threads).getPriority() + "]: " + count1!);
    print("Count 2 [priority " + second(threads).getPriority() + "]: " + count2!);
  }
  
  visualize {
    ret northAndCenter(vstackWithSpacing(
      withLabel("Multiplicity:", liveValueSpinner(dm_fieldLiveValue('multiplicity))),
      super.visualize()), 
    dm_printLogComponent());
  }
}