queueinputstream.java

JAVA网络编程技术内幕一书的源代码

/*
 * Java Network Programming, Second Edition
 * Merlin Hughes, Michael Shoffner, Derek Hamner
 * Manning Publications Company; ISBN 188477749X
 *
 * http://nitric.com/jnp/
 *
 * Copyright (c) 1997-1999 Merlin Hughes, Michael Shoffner, Derek Hamner;
 * all rights reserved; see license.txt for details.
 */

import java.io.*;

public class QueueInputStream extends MessageInput {
  protected Queue queue;
  
  public QueueInputStream (Queue queue) {
    super (new ByteArrayInputStream (new byte[0]));
    this.queue = queue;
  }

  public void receive () throws IOException {
    try {
      byte[] buffer = (byte[]) queue.remove ();
      in = new ByteArrayInputStream (buffer);
    } catch (InterruptedException ex) {
      throw new InterruptedIOException ("queue.remove()");
    }
  }
}