FutureTask.cancel

gistfile1.java

import org.junit.Test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;

public class StopTest {

    private final static ExecutorService es = Executors.newFixedThreadPool(10);
    @Test
    public void testStopTask() throws InterruptedException {
        Runnable nonstop = new Runnable() {
            public void run() {
                int c = 0;
                long start = System.currentTimeMillis();
                System.out.println(start);
                while( true ) { }
            }
        };
        FutureTask nonStopTask = new FutureTask(nonstop,null);
        es.execute(nonStopTask);
        Thread.sleep(10000L);
        nonStopTask.cancel(true);
        long end = System.currentTimeMillis();
        System.out.println(end);
    }
}