import java.util.concurrent.atomic.AtomicInteger;
import org.junit.Test;</BUG>
public class QueuedThreadPoolTest
{
final AtomicInteger _jobs=new AtomicInteger();
<BUG>volatile long _sleep=100;</BUG>
class RunningJob implements Runnable
{
<BUG>public volatile boolean _running=true;
public void run()</BUG>
{

import java.util.concurrent.atomic.AtomicInteger;
import junit.framework.Assert;
import org.junit.Test;
public class QueuedThreadPoolTest
{
final AtomicInteger _jobs=new AtomicInteger();
class RunningJob implements Runnable
{
private final CountDownLatch _latch = new CountDownLatch(3);
public void run()
{
