Потоки парковки в сервисе

Это не имеет ничего общего с регистратором, хотя его использование выводит проблему на поверхность. У вас есть состояние гонки, вот и все. Прежде чем объяснять это состояние гонки, вам нужно сначала понять несколько вещей из LockSupport::unpark документации:

Делает доступным разрешение для данного потока, если оно еще не было доступно. Если поток был заблокирован при парковке, он разблокируется. В противном случае следующий вызов функции парковки гарантированно не будет заблокирован.

Первый момент объясняется здесь. Краткая версия: если у вас есть thread, который уже запущен, но еще не вызвал park, и в течение этого периода времени (между start потока и park) какой-то другой поток вызывает unpark для первого: этот поток вообще не будет парковаться. Разрешение будет доступно немедленно. Может быть, этот маленький рисунок прояснит ситуацию:

(ThreadA)  start ------------------ park --------- ....

(ThreadB)  start ----- unpark -----

Обратите внимание, как ThreadB звонит unpark(ThreadA) между периодом, когда ThreadA звонил start, и park. Таким образом, когда ThreadA достигает park: блокировка гарантированно не, как и сказано в документации.

Второй пункт из той же документации:

Эта операция не гарантирует никакого эффекта, если данный поток не был запущен.

Давайте посмотрим, что через рисунок:

Thread B calls unpark(ThreadA) --- Thread A starts --- Thread A calls park 

После того, как ThreadA позвонит park, он зависнет навсегда, так как ThreadB больше никогда не позвонит unpark. Обратите внимание, что вызов unpark был сделан до запуска ThreadA (в отличие от предыдущего примера).

И это именно то, что происходит в вашем случае:

LockSupport.unpark(w); (от unparkWorkers) вызывается перед t.start(); от public void start(){...}. Проще говоря, ваш код вызывает unpark на обоих workers прежде чем они даже начнутся, поэтому, когда они в конечном итоге достигают park - они застревают, никто не может их unpark. Тот факт, что вы видите это с logger, а не с System::out, скорее всего, связан с тем, что когда вы println - под капотом есть метод synchronized.

На самом деле, LockSupport предлагает именно ту семантику, которая необходима для доказательства этого. Для этого нам понадобится (для простоты: SOProblem service = new SOProblem(1);)

static class ParkBlocker {

    private volatile int x;

    public ParkBlocker(int x) {
        this.x = x;
    }

    public int getX() {
        return x;
    }
}

И теперь нам нужно вставить это в соответствующие методы. Сначала отметьте тот факт, что мы вызвали unpark:

private void unparkWorkers() {
    Arrays.stream(workers).forEach(w -> {
        LockSupport.unpark(w);
        logger.debug("Un-park call is done on " + w.getName());
    });
    /*
     * add "1" to whatever there is already in pb.x, meaning
     * we have done unparking _also_
     */
    int y = pb.x;
    y = y + 1;
    pb.x = y;
}

Затем сбросьте флаг после завершения цикла:

public boolean stop(long timeout, TimeUnit unit) throws InterruptedException {
    boolean stoppedSuccefully = false;
    stopped = true;
    unparkWorkers();
    if (stopLatch.await(timeout, unit)) {
        stoppedSuccefully = true;
        // reset the flag
        pb.x = 0;
    }
    return stoppedSuccefully;
}

Затем измените конструктор, чтобы отметить, что поток запущен:

  .....
  while (!stopped) {
       logger.debug("Parking " + Thread.currentThread().getName());
       // flag the fact that thread has started. add "2", meaning
       // thread has started
       int y = pb.x;
       y = y + 2;
       pb.x = y;
       LockSupport.park(pb);
       logger.debug(Thread.currentThread().getName() + " unparked");
  }

Затем, когда ваш поток зависает, вам нужно проверить флаг:

 public static void main(String[] args) throws InterruptedException {
    while (true) {
        SOProblem service = new SOProblem(1); // <-- notice a single worker, for simplicity
        service.start();
        if (!service.stop(10000, TimeUnit.MILLISECONDS)) {
            service.debug();
            throw new RuntimeException();
        }
    }
}

где метод debug:

public void debug() {
    Arrays.stream(workers)
          .forEach(x -> {
              ParkBlocker pb = (ParkBlocker) LockSupport.getBlocker(x);
              if (pb != null) {
                  System.out.println("x = " + pb.getX());
              }
          });
}

Когда проблема повторяется, вы вызывали unpark до вызова park, что происходит, когда x = 3 является выходом.