[camel] branch master updated: CAMEL-15008: ReactiveExecutor should run scheduled tasks more fairly

[davsclaus]

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);
     }