Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

more robust test 

Signed-off-by: Greg Wilkins <gregw@webtide.com>
This commit is contained in:
Greg Wilkins 2018-02-28 14:28:58 +11:00
parent cd7432da95
commit 48eebacd6c
2 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jetty-util/src/main/java/org/eclipse/jetty/util/thread/strategy/ProduceExecuteConsume.java
View File

@ -102,7 +102,7 @@ public class ProduceExecuteConsume implements ExecutionStrategy
@Override @Override
public void dispatch() public void dispatch()
{ {
produce(); _executor.execute(()->produce());
} }
private enum State private enum State

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

@ -160,13 +160,12 @@ public class ExecutionStrategyTest
{ {
final int id = --tasks; final int id = --tasks;
if (id>=0) if (id>=0)
{
while(_threads.isRunning())
{ {
try try
{ {
final CountDownLatch latch = q.take(); final CountDownLatch latch = q.take();
if (latch!=null)
{
return new Runnable() return new Runnable()
{ {
@Override @Override
@ -177,20 +176,19 @@ public class ExecutionStrategyTest
} }
}; };
} }
}
catch(InterruptedException e) catch(InterruptedException e)
{ {
e.printStackTrace(); e.printStackTrace();
} }
} }
}
return null; return null;
} }
}; };
newExecutionStrategy(producer,_threads); newExecutionStrategy(producer,_threads);
_threads.execute(()->_strategy.produce()); _strategy.dispatch();
final CountDownLatch latch = new CountDownLatch(TASKS); final CountDownLatch latch = new CountDownLatch(TASKS);