利用多线程编写 生产者-消费者 关系

package ace;

import java.util.ArrayList;
import java.util.Timer;
import java.util.TimerTask;

/**
 * 利用多线程编写 生产者-消费者 关系
 */
public class ProductionAndConsumption {

	private static ArrayList<String> products = new ArrayList<String>(); // 产品
	private static int index = 0; // 产品编号

	public static void main(String[] args) {
		// 生产者线程
		final Thread t1 = new Thread(new Runnable() {
			// 每5秒生产一个产品
			public void run() {
				// 启动一个生产任务
				new Timer().schedule(new TimerTask() {
					public void run() {
						synchronized (products) {
							String product1 = "P" + index++, product2 = "P" + index++, product3 = "P" + index++;
							System.out.println("生产了产品:" + product1 + "、" + product2 + "、" + product3);
							products.add(product1);
							products.add(product2);
							products.add(product3);
						}
					}
				}, 1000, 5000); // 1s后开始任务，之后每5s执行一次
			}
		});

		// 消费者线程
		final Thread t2 = new Thread(new Runnable() {
			// 每秒消费一个产品
			public void run() {
				// 启动一个生产任务
				new Timer().schedule(new TimerTask() {
					public void run() {
						synchronized (products) {
							if (products.size() > 0) {
								System.out.println("消费了产品:" + products.get(0));
								products.remove(0);
							} else {
								System.out.println("没有产品可以消费");
							}
						}
					}
				}, 1000, 1000); // 1s后开始任务，之后每秒执行一次
			}
		});

		t1.start();
		t2.start();
	}

}