producer.java

英国帝国理工学院电脑系多线程课程教学材料之五 ---- 有限缓冲区范例

/*
@author  j.n.magee 20/04/98 revised 8.8.04
*/
package concurrency.buffer;

import concurrency.display.*;

/*******************PRODUCER************************/

class Producer implements Runnable {

    Buffer<Character> buf;
    String alphabet= "abcdefghijklmnopqrstuvwxyz";

    Producer(Buffer<Character> b) {buf = b;}

    public void run() {
      try {
        int ai = 0;
        while(true) {
            ThreadPanel.rotate(12);
            buf.put(alphabet.charAt(ai));
            ai=(ai+1) % alphabet.length();
            ThreadPanel.rotate(348);
        }
      } catch (InterruptedException e){}
    }
}