pipeimplbuf.java

来自「演示win32的socket 通讯 八皇后的改进算法 并发Concurren」· Java 代码 · 共 17 行

package concurrency.connector;

import concurrency.buffer.*;

public class PipeImplBuf implements Pipe {
  Buffer buf = new BufferImpl(10);

  public void put(Object o)
    throws InterruptedException {
    buf.put(o);
  }

  public Object get()
    throws InterruptedException {
    return buf.get();
  }
}