code: @Override
      protected void notifyDispatcher() {
          if (threads != null) {
              synchronized (threads) {
                  threads.notifyAll();
                  for (Thread thread : threads) {
                      ((DispatcherThread) thread).setChanged(true);
                  }
              }
          }
      }
docs: Notification about queue change