diff --git a/presto-main-base/src/main/java/com/facebook/presto/execution/SafeEventLoopGroup.java b/presto-main-base/src/main/java/com/facebook/presto/execution/SafeEventLoopGroup.java index 03932ef4ad49..bca2888c6b39 100644 --- a/presto-main-base/src/main/java/com/facebook/presto/execution/SafeEventLoopGroup.java +++ b/presto-main-base/src/main/java/com/facebook/presto/execution/SafeEventLoopGroup.java @@ -26,7 +26,6 @@ import java.util.concurrent.Executor; import java.util.concurrent.ThreadFactory; import java.util.function.Consumer; -import java.util.function.Supplier; import static java.util.Objects.requireNonNull; import static java.util.concurrent.TimeUnit.NANOSECONDS; @@ -75,7 +74,7 @@ protected void run() runTask(task); } catch (Throwable t) { - log.error("Error running task on event loop", t); + log.error(t, "Error executing task on event loop"); } updateLastExecutionTime(); } @@ -92,7 +91,7 @@ public void execute(Runnable task, Consumer failureHandler, Scheduler task.run(); } catch (Throwable t) { - log.error("Error executing task on event loop", t); + log.error(t, "Error executing method %s on event loop.", methodSignature); if (failureHandler != null) { failureHandler.accept(t); } @@ -106,24 +105,5 @@ public void execute(Runnable task, Consumer failureHandler, Scheduler } }); } - - public void execute(Supplier task, Consumer successHandler, Consumer failureHandler) - { - requireNonNull(task, "task is null"); - this.execute(() -> { - try { - T result = task.get(); - if (successHandler != null) { - successHandler.accept(result); - } - } - catch (Throwable t) { - log.error("Error executing task on event loop", t); - if (failureHandler != null) { - failureHandler.accept(t); - } - } - }); - } } }