多线程

http://www.java3z.com/cwbwebhome/article/article2/2875.html

二、一般用法举例

import java.io.Serializable;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class TestThreadPool {
 private static int produceTaskSleepTime = 2;
 private static int consumeTaskSleepTime = 2000;
 private static int produceTaskMaxNumber = 10;
 
public static void main(String[] args) {
//构造一个线程池
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 4, 3,TimeUnit.SECONDS, 
        new ArrayBlockingQueue(3),new ThreadPoolExecutor.CallerRunsPolicy());
for(int i=1;i<=produceTaskMaxNumber;i++){
  try {
   //产生一个任务，并将其加入到线程池
    String task = "task@ " + i;
    System.out.println("put " + task);
    threadPool.execute(new ThreadPoolTask(task));
    //便于观察，等待一段时间
    Thread.sleep(produceTaskSleepTime);
  } catch (Exception e) {
    e.printStackTrace();
  }
}
}
/**
线程池执行的任务 
@author hdpan 
*/
public static class ThreadPoolTask implements Runnable,Serializable{
  private static final long serialVersionUID = 0;
  //保存任务所需要的数据
  private Object threadPoolTaskData;
ThreadPoolTask(Object tasks){
  this.threadPoolTaskData = tasks;
}
public void run(){
  //处理一个任务，这里的处理方式太简单了，仅仅是一个打印语句
  System.out.println("start ..."+threadPoolTaskData);
  try {
    ////便于观察，等待一段时间
    Thread.sleep(consumeTaskSleepTime);
   } catch (Exception e) {
    e.printStackTrace();
  }
  threadPoolTaskData = null;
}
public Object getTask(){
  return this.threadPoolTaskData;
}
}
}



http://heipark.iteye.com/blog/1156011

public class Test {

    public static void main(String[] args) {
        BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
        ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 6, 1, TimeUnit.DAYS, queue);

        for (int i = 0; i < 20; i++) {
            final int index = i;
            executor.execute(new Runnable() {
                public void run() {
                    try {
                        Thread.sleep(4000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(String.format("thread %d finished", index));
                }
            });
        }
        executor.shutdown();
    }
}