@@ -365,73 +365,4 @@ public EngineRunningState getEngineRunningState() {
365365 return engineRunningState ;
366366 }
367367
368- // @Internal
369- // public boolean isRunning() {
370- // return isRunning.get() > 0;
371- // }
372- //
373- // private void incrementRunning(Throwable throwable) {
374- // assertTrue(isRunning.get() >= 0);
375- // if (isRunning.incrementAndGet() == 1) {
376- // changeOfState(RUNNING);
377- // }
378- // }
379- //
380- // private void decrementRunning(Throwable throwable) {
381- // assertTrue(isRunning.get() > 0);
382- // if (isRunning.decrementAndGet() == 0) {
383- // changeOfState(NOT_RUNNING);
384- // }
385- // }
386- //
387- // @Internal
388- // public void incrementRunning(CompletableFuture<?> cf) {
389- // cf.whenComplete((result, throwable) -> {
390- // incrementRunning(throwable);
391- // });
392- // }
393- //
394- // @Internal
395- // public void decrementRunning(CompletableFuture<?> cf) {
396- // cf.whenComplete((result, throwable) -> {
397- // decrementRunning(throwable);
398- // });
399- //
400- // }
401- //
402- // @Internal
403- // public <T> T call(Supplier<T> callable) {
404- // return call(null, callable);
405- // }
406- //
407- // @Internal
408- // public <T> T call(Throwable throwable, Supplier<T> callable) {
409- // incrementRunning(throwable);
410- // try {
411- // return callable.get();
412- // } finally {
413- // decrementRunning(throwable);
414- // }
415- // }
416- //
417- // @Internal
418- // public void run(Runnable runnable) {
419- // run(null, runnable);
420- // }
421- //
422- // @Internal
423- // public void run(Throwable throwable, Runnable runnable) {
424- // incrementRunning(throwable);
425- // try {
426- // runnable.run();
427- // } finally {
428- // decrementRunning(throwable);
429- // }
430- // }
431- //
432- // private void changeOfState(RunningState runningState) {
433- // if (engineRunningObserver != null) {
434- // engineRunningObserver.runningStateChanged(executionId, graphQLContext, runningState);
435- // }
436- // }
437368}
0 commit comments