private void syncPoolThreads() {
    var barrier = new CyclicBarrier(myThreadsCount + 1);
    for (int i = 0; i < myThreadsCount; i++) {
      myExecutor.execute(() -> waitBarrier(barrier));
    }
    waitBarrier(barrier);
  }
private void syncPoolThreads()