QNX/UNIX: Анатомия параллелизма

#include <sys/neutrino.h>
#include <sys/syspage.h>
#include <sys/netmgr.h>
#include <pthread.h>
#include <signal.h>
#include <algorithm>
static void out(char s) {
 int policy;
 sched_param param;
 pthread_getschedparam(pthread_self(), &policy, &param);
 cout << s << param.sched_curpriority << flush;
}
// целевые функции каждой из последовательностей только
// выводят свой символ-идентификатор и следующий за ним
// приоритет, на котором выполняется целевая функция
static void mon1(void) { out('.'); }
static void mon2(void) { out('*'); }
static void mon3(void) { out('+'); }
// это всего лишь перерасчет временных интервалов,
// измеренных в тактах процессора (в наносекундах)
inline uint64_t cycles2nsec(uint64_t с) {
 const static uint64_t cps =
  // частота процессора
  SYSPAGE_ENTRY(qtime)->cycles_per_sec;
 return (с * 1000000000) / cps;
}
// структура, необходимая только для накопления статистики параметров
// ряда временных отметок: среднего, среднеквадратичного отклонения,
// минимального и максимального значений
struct timestat {
private:
 uint64_t prev;
public:
 uint64_t num;
 double mean, disp, tmin, tmax;
 timestat(void) {
  mean = disp = tmin = tmax = 0.0;
  num = 0;
 }
 // новая временная отметка в ряду:
 void operator++(void) {
  uint64_t next = ClockCycles(), delta;
  if (num i= 0) {
   double delta = cycles2nsec(next — prev);
   if (num == 1) tmin = tmax = delta;
   else tmin = min(tmin, delta), tmax = max(tmax, delta);
   mean += delta;
   disp += delta * delta;
  }
  prev = next;
  num++;
 }
 // подвести итог ряда;
 void operator !(void) {
  mean /= (num - 1);
  disp = sqrt(disp / (num - 1) - mean * mean);
 }
}
// предварительное описание функции потока объекта
void* syncthread(void*);
class thrblock {
private:
 static int code;
 bool ok, st;
public:
 pthread_t tid;
 struct sigevent event;
 timer_t timer;
 int chid;
 void* (*func)(void*);
 sched_param param;
 // структура только для статистики:
 timestat sync;
 // конструктор класса - он не только инициализирует структуру данных
 // создаваемого объекта, но и запускает отдельный поток для его исполнения
 thrblock(
  // параметры конструктора
  // - целевая функция последовательности
  void (*dofunc)(void);
  // - период ее синхронизации
  unsigned long millisec;
  // - приоритет возбуждения синхросерии
  unsigned short priority;
  // - копить ли статистику временных интервалов?
  bool statist = false
 ) {
  // создание канала для получения уведомлений от таймера
  if (!(ok = ((chid = ChannelCreate(0)) >= 0))) return;
  // создать соединение по каналу, которое будет использовать таймер
  event.sigev_coid =
   ConnectAttach(ND_LOCAL_NODE, 0, chid, NTO_SIDE_CHANNEL, 0);
  if (!(ok = (event.sigev_coid >= 0))) return;
  // занести целевую функцию, заодно выполнив