presto-main/src/main/java/io/prestosql/execution/SqlStageExecution.java/ListenerManager/invoke
class ListenerManager:        public synchronized void invoke(T payload, Executor executor)
        {
            frozen = true;
            for (Consumer<T> listener : listeners) {
                executor.execute(() -> listener.accept(payload));
            }
        }