java thread, ExecutorSerivce example

ThreadExample1.java

/**
 * Runnable을 상속한 스레드 예제 
 * 
 * @author User
 *
 */
public class ThreadExample1 implements Runnable {

	@Override
	public void run() {
		
		int count = 0;
		do {
			System.out.printf("%s %d\n", Thread.currentThread().getName(), count++);
		} while(count < 10);
	}

	public static void main(String[] args) {
		
		new Thread(new ThreadExample1()).start();
		new Thread(new ThreadExample1()).start();
	}
}

ThreadExample2.java

/**
 * Thread를 상속한 예제  
 * 
 * @author User
 *
 */
public class ThreadExample2 extends Thread {

	@Override
	public void run() {
		
		int count = 0;
		do {
			System.out.printf("%s %d\n", Thread.currentThread().getName(), count++);
		} while(count < 10);
	}

	public static void main(String[] args) {
		
		new Thread(new ThreadExample2()).start();
		new Thread(new ThreadExample2()).start();
	}
}

ThreadExample3.java

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

/**
 * 스레드풀 처리 예제
 * Runnable 을 이용하여 결과값을 반환받지 않는 예제 
 * 
 * @author User
 *
 */
public class ThreadExample3 extends Thread {

	@Override
	public void run() {

		int count = 0;
		do {
			System.out.printf("%s %d\n", Thread.currentThread().getName(), count++);
		} while (count < 10);
	}

	public static void main(String[] args) {

		ExecutorService service = Executors.newCachedThreadPool();
		service.execute(new ThreadExample3());
		service.execute(new ThreadExample3());
		service.execute(new ThreadExample3());
		service.execute(new ThreadExample3());
		service.execute(new ThreadExample3());
		service.execute(new ThreadExample3());
		service.execute(new ThreadExample3());
		service.execute(new ThreadExample3());
		service.execute(new ThreadExample3());
		service.shutdown();
	}
}

ThreadExample4.java

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 * 스레드풀 처리 예제 
 * 
 * @author User
 *
 */
public class ThreadExample4 {

	
	public static void main(String[] args) throws InterruptedException, ExecutionException {
	
//		ExecutorService service = Executors.newCachedThreadPool();
		ExecutorService service = Executors.newFixedThreadPool(100);
		
		Future<Integer> future1 = service.submit(new CallableSample());
		Future<Integer> future2 = service.submit(new CallableSample());
		Future<Integer> future3 = service.submit(new CallableSample());
		
		System.out.println(future1.get());
		System.out.println(future2.get());
		System.out.println(future3.get());
		
		service.shutdown();
	}

}

class CallableSample implements Callable<Integer> {

	public CallableSample() {
		System.out.println("Callable construct");
	}
	
	@Override
	public Integer call() throws Exception {
		System.out.println("call");
		
		int result = (int) (Math.random() * 10) + 1;
		Thread.sleep(result*1000);
		return result;
	}
}