java中的线程安全InputStream

如何创建一个Thread安全的InputStream.在多线程操作中,inputStream数据被破坏,所以如何使我的inputStream线程安全.将使用以下代码工作

public class SynchronizedInputStream  extends InputStream{

    private InputStream in;

    private SynchronizedInputStream( InputStream in ) {
        this.in = in;
    }

    /* ... method for every InputStream type to use */
    public  static InputStream createInputStream( InputStream in) {
        return new SynchronizedInputStream( in);
    }

    public static InputStream createPushBackInputStream(InputStream in,int BUFSIZE){
        return new SynchronizedInputStream(new PushbackInputStream(in,BUFSIZE));
    }

    /* Wrap all InputStream methods Used */

    public int read(){
        synchronized (this) {
            try {
                return in.read();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return 0;
    }

    @Override
    public int available() {
        synchronized( this ) {
            try {
                return in.available();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return 0;
    }


}

在NANOHTTPD文件中

 public HTTPSession(TempFileManager tempFileManager, InputStream inputStream, OutputStream outputStream, InetAddress inetAddress) {
            this.inputStream=(PushbackInputStream) SynchronizedInputStream.createPushBackInputStream(inputStream);
        /*lines of code..........*/
        }

然后我就这样称呼它

String Data = readStream(session.getInputStream());//session is HTTPSession
/*.....code....*/
private String readStream(InputStream in) {
        synchronized (in) {
            PushbackInputStream inputStream = (PushbackInputStream) in;
            StringBuffer outputBuffer = null;
            try {
                                 //Reading the InputStream Here
                }
            } catch (IOException ioe) {
                //error msg
            }
                return outputBuffer.toString();

        } 
    }

Enno Shioji.. 9

你需要考虑它是如何有意义的.想象一下,不止一个人正在阅读一本魔法书,它会在人们第一次看到它时删除这个角色.所以只有一个人可以阅读任何给定的角色.这就是流的方式.

这使得以有用的方式阅读本书变得非常困难.当最天真地完成时,每个人都会得到一些随机的角色子集; 不是很有用的信息.

一个直接的解决方案是让一个人阅读它,然后将其复制到一本书上,当一个人读取它时不会删除字符.这样每个人都可以阅读这本书.在某些情况下,你并不需要每个人都能理解这本书,只要给出一个句子,人们就可以工作.在这种情况下,一个读者可以将每个句子发布到一个队列,每个人每次都要一个句子.

其他方法包括具有缓冲区,其中每个线程存储它们读取的字符,然后每次检查它们是否可以形成单词,并且如果是这样则发出单词用于下游处理.有关示例,请参阅Netty的编解码器包(例如,此).

然而,这些方法通常在流的顶部而不是在流内部实现.你可能有一个在里面做这些的流,但它可能会让人迷惑.