code: private void initialize()
      {
          activeOperators.stream()
                  .map(Operator::getOperatorContext)
                  .forEach(operatorContext -> operatorContext.setMemoryRevocationRequestListener(() -> driverBlockedFuture.get().set(null)));
      }
docs: another thread, which will cause unsafe publication of this instance.