myprocon.java

来自「本博客系统是在J2EE平台上用Hibernate框架技术和MVC模式构建」· Java 代码 · 共 53 行

 import java.util.*;
    class Producer extends Thread {
       private Store store;
       private int num;
       public Producer(Store s, int num) {
          store=s;
          this.num=num;
       } //构造方法
       public void run() {
          for (int i=0; i<10; i++) {
             store.put(i); //放i到store对象
             System.out.println("Producer #"+this.num+"put:"+i); //显示放数i
             try {
                sleep ((int)(Math.random()*100)); //休眠0-100毫秒
             } catch(InterruptedException e) {
             }
          }
       } //线程体
    } //生产者Producer线程
    class Consumer extends Thread {
       private Store store;
       private int num;
       public Consumer(Store s, int num) {
          store=s;
          this.num=num;
       } //构造方法
       public void run() {
          int value=0;
          for (int i=0; i<10; i++) {
             value=store.get(); //从store对象取值
             System.out.println("Consumer #"+this.num+"got:"+value);
          }
       } //线程体
    } //消费者Consumer线程
    class MyProCon {
       public static void main (String args[]) {
          Store s=new Store();
          Producer p1=new Producer(s,1);
          Consumer c1=new Consumer(s,1);
          p1.start();
          c1.start();
       }
    }
    class Store {
       private int seq;
       public int get() {
          return seq;
       }
       public void put(int value) {
          seq=value;
       }
    }