利用多线程编写 生产者-消费者 关系
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(); } }
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。