minor cleanups

jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/HTTP2Connection.java

@@ -58,17 +58,9 @@ public HTTP2Connection(ByteBufferPool byteBufferPool, Executor executor, EndPoin
         this.parser = parser;
         this.session = session;
         this.bufferSize = bufferSize;
-        this.strategy = new EatWhatYouKill(producer, executor,InvocationType.BLOCKING, InvocationType.BLOCKING, 0);
+        this.strategy = new EatWhatYouKill(producer, executor, 0);
 
-        // TODO clean this up.
-        try
-        {
-            ((LifeCycle)this.strategy).start();
-        }
-        catch (Exception e)
-        {
-            throw new RuntimeException(e);
-        }
+        LifeCycle.start(strategy);
     }
 
     @Override
@@ -113,16 +105,8 @@ public void onClose()
         if (LOG.isDebugEnabled())
             LOG.debug("HTTP2 Close {} ", this);
         super.onClose();
-
-        // TODO clean this up.
-        try
-        {
-            ((LifeCycle)this.strategy).stop();
-        }
-        catch (Exception e)
-        {
-            throw new RuntimeException(e);
-        }
+
+        LifeCycle.stop(strategy);
     }
 
     @Override

jetty-util/src/main/java/org/eclipse/jetty/util/component/LifeCycle.java

@@ -122,4 +122,47 @@ public interface Listener extends EventListener
         public void lifeCycleStopping(LifeCycle event);
         public void lifeCycleStopped(LifeCycle event);
     }
+
+
+    /**
+     * Utility to start an object if it is a LifeCycle and to convert
+     * any exception thrown to a {@link RuntimeException}
+     * @param object The instance to start.
+     * @throws RuntimeException if the call to start throws an exception.
+     */
+    public static void start(Object object)
+    {
+        if (object instanceof LifeCycle)
+        {
+            try
+            {
+                ((LifeCycle)object).start();
+            }
+            catch(Exception e)
+            {
+                throw new RuntimeException(e);
+            }
+        }
+    }
+
+    /**
+     * Utility to stop an object if it is a LifeCycle and to convert
+     * any exception thrown to a {@link RuntimeException}
+     * @param object The instance to stop.
+     * @throws RuntimeException if the call to stop throws an exception.
+     */
+    public static void stop(Object object)
+    {
+        if (object instanceof LifeCycle)
+        {
+            try
+            {
+                ((LifeCycle)object).stop();
+            }
+            catch(Exception e)
+            {
+                throw new RuntimeException(e);
+            }
+        }
+    }
 }

jetty-util/src/main/java/org/eclipse/jetty/util/thread/Invocable.java

@@ -195,38 +195,38 @@ public static class InvocableExecutor implements Executor
         private static final Logger LOG = Log.getLogger(InvocableExecutor.class);
 
         private final Executor _executor;
-        private final InvocationType _preferredExecutionType;
-        private final InvocationType _preferredInvocationType;
+        private final InvocationType _preferredInvocationForExecute;
+        private final InvocationType _preferredInvocationForInvoke;
 
         public InvocableExecutor(Executor executor,InvocationType preferred)
         {
             this(executor,preferred,preferred);
         }
 
-        public InvocableExecutor(Executor executor,InvocationType preferredForExecution,InvocationType preferredForIvocation)
+        public InvocableExecutor(Executor executor,InvocationType preferredInvocationForExecute,InvocationType preferredInvocationForIvoke)
         {
             _executor=executor;
-            _preferredExecutionType=preferredForExecution;
-            _preferredInvocationType=preferredForIvocation;
+            _preferredInvocationForExecute=preferredInvocationForExecute;
+            _preferredInvocationForInvoke=preferredInvocationForIvoke;
         }
 
         public Invocable.InvocationType getPreferredInvocationType()
         {
-            return _preferredInvocationType;
+            return _preferredInvocationForInvoke;
         }
 
         public void invoke(Runnable task)
         {
             if (LOG.isDebugEnabled())
                 LOG.debug("{} invoke  {}", this, task);
-            Invocable.invokePreferred(task,_preferredInvocationType);
+            Invocable.invokePreferred(task,_preferredInvocationForInvoke);
             if (LOG.isDebugEnabled())
                 LOG.debug("{} invoked {}", this, task);
         }
 
         public void execute(Runnable task)
         {
-            tryExecute(task,_preferredExecutionType);
+            tryExecute(task,_preferredInvocationForExecute);
         }
 
         public void execute(Runnable task, InvocationType preferred)
@@ -236,7 +236,7 @@ public void execute(Runnable task, InvocationType preferred)
 
         public boolean tryExecute(Runnable task)
         {
-            return tryExecute(task,_preferredExecutionType);
+            return tryExecute(task,_preferredInvocationForExecute);
         }
 
         public boolean tryExecute(Runnable task, InvocationType preferred)

jetty-util/src/main/java/org/eclipse/jetty/util/thread/strategy/EatWhatYouKill.java

@@ -66,16 +66,21 @@ public EatWhatYouKill(Producer producer, Executor executor)
         this(producer,executor,InvocationType.NON_BLOCKING,InvocationType.BLOCKING);
     }
 
-    public EatWhatYouKill(Producer producer, Executor executor, InvocationType preferredExecution, InvocationType preferredInvocation)
+    public EatWhatYouKill(Producer producer, Executor executor, int maxProducersPending )
     {
-        this(producer,executor,preferredExecution,preferredInvocation,1);
+        this(producer,executor,InvocationType.NON_BLOCKING,InvocationType.BLOCKING);
     }
 
-    public EatWhatYouKill(Producer producer, Executor executor, InvocationType preferredExecution, InvocationType preferredInvocation, int maxProducersPending )
+    public EatWhatYouKill(Producer producer, Executor executor, InvocationType preferredInvocationPEC, InvocationType preferredInvocationEPC)
+    {
+        this(producer,executor,preferredInvocationPEC,preferredInvocationEPC,1);
+    }
+
+    public EatWhatYouKill(Producer producer, Executor executor, InvocationType preferredInvocationPEC, InvocationType preferredInvocationEPC, int maxProducersPending )
     {
         _producer = producer;
         _pendingProducersMax = maxProducersPending;
-        _executor = new InvocableExecutor(executor,preferredExecution,preferredInvocation);
+        _executor = new InvocableExecutor(executor,preferredInvocationPEC,preferredInvocationEPC);
     }
 
     @Override
@@ -167,12 +172,15 @@ private boolean pendingProducerWait()
                     // spurious wakeup!
                     _pendingProducers--;
                 } 
-                else if (_state == State.IDLE)                    
+                else
                 {
                     _pendingProducersSignalled--;
-                    _state = State.PRODUCING;
-                    return true;
-                } 
+                    if (_state == State.IDLE)                    
+                    {
+                        _state = State.PRODUCING;
+                        return true;
+                    } 
+                }
             }
             catch (InterruptedException e)
             {

jetty-util/src/test/java/org/eclipse/jetty/util/thread/strategy/ExecutionStrategyTest.java

@@ -67,8 +67,7 @@ public ExecutionStrategyTest(Class<? extends ExecutionStrategy> strategy)
     void newExecutionStrategy(Producer producer, Executor executor) throws Exception
     {
         _strategy = _strategyClass.getConstructor(Producer.class,Executor.class).newInstance(producer,executor);
-        if (_strategy instanceof LifeCycle)
-            ((LifeCycle)_strategy).start();
+        LifeCycle.start(_strategy);
     }
 
     @Before
@@ -80,8 +79,7 @@ public void before() throws Exception
     @After
     public void after() throws Exception
     {
-        if (_strategy instanceof LifeCycle)
-            ((LifeCycle)_strategy).stop();
+        LifeCycle.stop(_strategy);
         threads.stop();
     }