This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push: new 008eaec CAMEL-15008: ReactiveExecutor should run scheduled tasks more fairly 008eaec is described below commit 008eaec2c7145d8f704080da115403be35e4696a Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Mon May 4 17:40:36 2020 +0200 CAMEL-15008: ReactiveExecutor should run scheduled tasks more fairly --- .../src/main/java/org/apache/camel/spi/ReactiveExecutor.java | 11 ++--------- .../org/apache/camel/impl/engine/DefaultReactiveExecutor.java | 5 ----- 2 files changed, 2 insertions(+), 14 deletions(-) diff --git a/core/camel-api/src/main/java/org/apache/camel/spi/ReactiveExecutor.java b/core/camel-api/src/main/java/org/apache/camel/spi/ReactiveExecutor.java index 3f30d59..23e6489 100644 --- a/core/camel-api/src/main/java/org/apache/camel/spi/ReactiveExecutor.java +++ b/core/camel-api/src/main/java/org/apache/camel/spi/ReactiveExecutor.java @@ -27,20 +27,13 @@ public interface ReactiveExecutor { String FACTORY = "reactive-executor"; /** - * Schedules the task to be run + * Schedules the task to be run (fairly) * * @param runnable the task */ void schedule(Runnable runnable); /** - * Schedules the task to be run first - * - * @param runnable the task - */ - void scheduleFirst(Runnable runnable); - - /** * Schedules the task to be prioritized and run asap * * @param runnable the task @@ -48,7 +41,7 @@ public interface ReactiveExecutor { void scheduleMain(Runnable runnable); /** - * Schedules the task to run synchronously + * Schedules the task to run synchronously (current thread) * * @param runnable the task */ diff --git a/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java b/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java index ccf7094..3b6c1c7 100644 --- a/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java +++ b/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java @@ -56,11 +56,6 @@ public class DefaultReactiveExecutor extends ServiceSupport implements ReactiveE } @Override - public void scheduleFirst(Runnable runnable) { - workers.get().schedule(runnable, true, false, false); - } - - @Override public void scheduleMain(Runnable runnable) { workers.get().schedule(runnable, true, true, false); }