线程池

public abstract class  {

  private static final AtomicInteger ID_GENERATOR = new AtomicInteger();

  private final int id;
  private final int timeMs;

  public (final int timeMs) {
    this.id = ID_GENERATOR.incrementAndGet();
    this.timeMs = timeMs;
  }

  public int getId() {
    return id;
  }

  public int getTimeMs() {
    return timeMs;
  }

  
  public String toString() {
    return String.format("id=%d timeMs=%d", id, timeMs);
  }
}

public class Worker implements Runnable {

  private static final Logger LOGGER = LoggerFactory.getLogger(Worker.class);

  private final Task task;

  public Worker(final Task task) {
    this.task = task;
  }

  
  public void run() {
    LOGGER.info("{} 正在处理任务: [{}]", Thread.currentThread().getName(), task.toString());
    try {
      Thread.sleep(task.getTimeMs());
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
}

 * 
 * 土豆去皮任务
 *
 */
public class PotatoPeelingTask extends  {

 
    * 每个土豆去皮的时间
     */
   private static final int TIME_PER_POTATO = 200;

 public PotatoPeelingTask(int numPotatoes) {
       super(numPotatoes * TIME_PER_POTATO);
   }

   
 public String toString() {
     return String.format("%s %s", this.getClass().getSimpleName(), super.toString());
 }
}

 * 
 * 制作咖啡任务
 * 
 */
public class CoffeeMakingTask extends  {

  
    * 每杯咖啡制作时间
  */
   private static final int TIME_PER_CUP = 100;

    public CoffeeMakingTask(int numCups) {
        super(numCups * TIME_PER_CUP);
  }

   
 public String toString() {
     return String.format("%s %s", this.getClass().getSimpleName(), super.toString());
 }
}

public static void main(String[] args) {

    LOGGER.info("Program started");

    // Create a list of tasks to be executed
    List<Task> tasks = new ArrayList<>();
    tasks.add(new PotatoPeelingTask(3));
    tasks.add(new PotatoPeelingTask(6));
    tasks.add(new CoffeeMakingTask(2));
    tasks.add(new CoffeeMakingTask(6));
    tasks.add(new PotatoPeelingTask(4));
    tasks.add(new CoffeeMakingTask(2));
    tasks.add(new PotatoPeelingTask(4));
    tasks.add(new CoffeeMakingTask(9));
    tasks.add(new PotatoPeelingTask(3));
    tasks.add(new CoffeeMakingTask(2));
    tasks.add(new PotatoPeelingTask(4));
    tasks.add(new CoffeeMakingTask(2));
    tasks.add(new CoffeeMakingTask(7));
    tasks.add(new PotatoPeelingTask(4));
    tasks.add(new PotatoPeelingTask(5));

    // Creates a thread pool that reuses a fixed number of threads operating off a shared
    // unbounded queue. At any point, at most nThreads threads will be active processing
    // tasks. If additional tasks are submitted when all threads are active, they will wait
    // in the queue until a thread is available.
    ExecutorService executor = Executors.newFixedThreadPool(3);

    // Allocate new worker for each task
    // The worker is executed when a thread becomes
    // available in the thread pool
    for (int i = 0; i < tasks.size(); i++) {
      Runnable worker = new Worker(tasks.get(i));
         executor.execute(worker);
    }
    // All tasks were executed, now shutdown
    executor.shutdown();
    while (!executor.isTerminated()) {
      Thread.yield();
    }
    LOGGER.info("Program finished");
  }
}