static L<CriticalAction> beginCriticalAction_inFlight = synchroList();

sclass CriticalAction {
  S description;
  
  *() {}
  *(S *description) {}
  
  void done() {
    beginCriticalAction_inFlight.remove(this);
  }
}

static CriticalAction beginCriticalAction(S description) {
  ping();
  CriticalAction c = new CriticalAction(description);
  beginCriticalAction_inFlight.add();
  ret c;
}

svoid cleanMeUp_beginCriticalAction() {
  int n = 0;
  while (nempty(beginCriticalAction_inFlight)) {
    int m = l(beginCriticalAction_inFlight);
    if (m != n) {
      n = m;
      print("Waiting for " + n(n, "critical actions"));
    }
    sleepInCleanUp(10);
  }
}