Apple_多线程小例子.docxVIP

package Test5_8_apple;/** * 〈一句话功能简述〉br * 〈功能详细描述〉 厂家一共要生产20苹果，摊位上最多只能摆6个买，商家不断向摊位上补充苹果， * 同时消费者在买苹果（注意：摊位上苹果最多6个，如果为0个则不能消费，消费者买完20个苹果后结束）， * 请用多线程写一段程序完成这个需求。 * @see [相关类/方法]（可选） * @since [产品/模块版本] （可选） */public class Apple {private int id;public Apple(int id){this.id=id;}public String toString(){return Apple+id;}public static void main(String[] args) { StackBasket s=new StackBasket(); Producer p=new Producer(s); Consumer c=new Consumer(s); Thread tp=new Thread(p); Thread tc=new Thread(c); tp.start(); tc.start(); }}/** * 消费线程 * */ class Consumer implements Runnable{ StackBasket ss=new StackBasket(); public Consumer(StackBasket ss) { this.ss=ss; } /** * 一共消费20个苹果 */ public void run() { for(int i=0;i20;i++){ Apple apple=ss.consume(); try { Thread.sleep((int)(Math.random()*500)); } catch (InterruptedException e) { e.printStackTrace(); } } }} /** * *生产线程 */ class Producer implements Runnable{ StackBasket ss=new StackBasket(); public Producer(StackBasket ss) { this.ss=ss; } /** * 一共生产20个苹果 */ @Override public void run() { for(int i=0;i20;i++){ Apple apple=new Apple(i); ss.produce(apple); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } } } /** * *内存空间，相当于放苹果的篮子 */class StackBasket { Apple apple[]=new Apple[6]; int index=0; /** * 生产方法 * 首先判断满否，满的话使该线程等待，释放同步方法锁，允许消费 * 不满首先唤醒正在等待的消费方法，但是也只能让其进入就绪状态 * @param m */ public synchronized void produce(Apple app){ try{ while(index==apple.length){ System.out.println(###########生产满了################); this.wait(); } this.notify(); }catch(Exception e){ e.printStackTrace(); } apple[index]=app; index++; System.out.println(生产了：+app+共有+index+个苹果); } /** * 消费苹果，如果篮子中没有了则该线程处于阻塞状态 * @return */ public synchronized Apple consume(){ try{ while(index==0){ System.out.println(#######消费光了#######); this.wait(); } this.notify(); }catch(Exception e){ e.printStackTrace(); } index--; System.out.println(消费：-------+apple[index]+还剩+index+个苹果); return apple[index]; } }package Test5_8_apple;import java.util