package thread.base;

/**
 * User: likang
 * Date: 16/8/14
 * Time: 下午4:27
 */
public class TestThread extends Thread {
    private Integer index;
    private String name;

    public TestThread(String name, Integer index) {
        this.name = name;
        this.index = index;
    }

    public void run() {
        try {
            Thread.sleep(1000l);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(name + "Thread index:" + index);
    }
}

package thread.base;

/**
 * User: likang
 * Date: 16/8/14
 * Time: 下午4:32
 */
public class TestRunnable implements Runnable {
    private Integer index;
    private String name;

    public TestRunnable(String name, Integer index) {
        this.name = name;
        this.index = index;
    }

    public void run() {
        try {
            Thread.sleep(1000l);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(name + "Runnable index:" + index);
    }
}

package thread.base;

import java.util.concurrent.Callable;

/**
 * User: likang
 * Date: 16/8/14
 * Time: 下午4:35
 */
public class TestCallable implements Callable<String> {
    private Integer index;
    private String name;

    public TestCallable(String name, Integer index) {
        this.name = name;
        this.index = index;
    }

    @Override
    public String call() throws Exception {
        try {
            Thread.sleep(1000l);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return name + "Callable index:" + index;
    }
}

import thread.base.TestCallable;
import thread.base.TestRunnable;
import thread.base.TestThread;

import java.util.concurrent.*;

/**
 * User: likang
 * Date: 16/8/14
 * Time: 下午4:26
 */
public class ThreadTest {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        System.out.println("测试第一部分 Thread");
        for (Integer i = 0; i < 5; i++) {
            TestThread testThread = new TestThread("第一部分 ", i);
            testThread.start();
        }
        System.out.println("测试第二部分 Runnable+Thread");
        for (Integer i = 0; i < 5; i++) {
            TestRunnable testRunnable = new TestRunnable("第二部分 ", i);
            new Thread(testRunnable).start();
        }
        System.out.println("测试第三部分 Callable+Thread");
        for (Integer i = 0; i < 5; i++) {
            TestCallable testCallable = new TestCallable("第三部分 ", i);
            FutureTask<String> futureTask = new FutureTask<String>(testCallable);
            new Thread(futureTask).start();

            String result = futureTask.get();
            System.out.println(result);
        }
        System.out.println("测试第四部分 Runnable+CachedThreadPool");
        for (Integer i = 0; i < 5; i++) {
            ExecutorService executorService = Executors.newCachedThreadPool();
            TestRunnable testRunnable = new TestRunnable("第四部分 ", i);
            executorService.submit(testRunnable);
        }
        System.out.println("测试第五部分 Runnable+CachedThreadPool");
        for (Integer i = 0; i < 5; i++) {
            ExecutorService executorService = Executors.newCachedThreadPool();
            TestCallable testCallable = new TestCallable("第五部分 ", i);
            Future<String> future = executorService.submit(testCallable);
            System.out.println(future.get());
        }
        System.out.println("测试第六部分 Callable+CompletionService+CachedThreadPool");
        ExecutorService executorService = Executors.newCachedThreadPool();
        CompletionService<String> completionService = new ExecutorCompletionService<String>(executorService);
        for (Integer i = 0; i < 5; i++) {
            TestCallable testCallable = new TestCallable("第六部分 ", i);
            completionService.submit(testCallable);
        }
        for (Integer i = 0; i < 5; i++) {
            Future<String> future = completionService.take();
            System.out.println(future.get());
        }
        System.out.println("End");
    }
}