執行緒 生產者 消費者 例題
阿新 • • 發佈:2022-04-02
package com.cj.java1; class Producer extends Thread{ private Clerk clerk; public Producer(Clerk clerk){ this.clerk = clerk; } @Override public void run() { System.out.println("開始生產"); while (true){ try { Thread.sleep(20); }catch (InterruptedException e) { e.printStackTrace(); } clerk.addProduct(); } } } class Clerk{ private int productCount = 0; public synchronized void addProduct() { if (productCount<20){ productCount++; System.out.println(Thread.currentThread().getName()+ "開始生產第:"+productCount+"個產品"); notify(); }else{ try { wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } public synchronized void decProduct() { if (productCount>0){ System.out.println(Thread.currentThread().getName()+ "開始消費第:"+productCount+"個產品"); productCount--; notify(); }else{ try { wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } } class Customer extends Thread{ private Clerk clerk; public Customer(Clerk clerk){ this.clerk = clerk; } @Override public void run() { System.out.println("開始消費"); while (true){ try { Thread.sleep(10); } catch (InterruptedException e) { e.printStackTrace(); } clerk.decProduct(); } } } public class ProductTest { public static void main(String[] args) { Clerk clerk = new Clerk(); Producer producer = new Producer(clerk); Customer customer = new Customer(clerk); producer.setName("生產者"); customer.setName("消費者"); producer.start(); customer.start(); } }