多线程设置模式 －－ Read-Write Lock Pattern

核心提示： 读线程 Java代码publicclassReaderThreadextendsThread{privatefinalDatadata;publicReaderThread(Datadata){this.data=data;}publicvoidrun(){try{while(true){cha

读线程

Java代码　　　

public　class　ReaderThread　extends　Thread　{　
　　private　final　Data　data;　
　　public　ReaderThread(Data　data)　{　
　　　　this.data　=　data;　
　　}　
　　public　void　run()　{　
　　　　try　{　
　　　　　　while　(true)　{　
　　　　　　　　char[]　readbuf　=　data.read();　
　　　　　　　　System.out.println(Thread.currentThread().getName()　+　"　reads　"　+　String.valueOf(readbuf));　
　　　　　　}　
　　　　}　catch　(InterruptedException　e)　{　
　　　　}　
　　}　
}

写线程

Java代码　　　

public　class　WriterThread　extends　Thread　{　
　　private　static　final　Random　random　=　new　Random();　
　　private　final　Data　data;　
　　private　final　String　filler;　
　　private　int　index　=　0;　
　　public　WriterThread(Data　data,　String　filler)　{　
　　　　this.data　=　data;　
　　　　this.filler　=　filler;　
　　}　
　　public　void　run()　{　
　　　　try　{　
　　　　　　while　(true)　{　
　　　　　　　　char　c　=　nextchar();　
　　　　　　　　data.write(c);　
　　　　　　　　Thread.sleep(random.nextInt(3000));　
　　　　　　}　
　　　　}　catch　(InterruptedException　e)　{　
　　　　}　
　　}　
　　private　char　nextchar()　{　
　　　　char　c　=　filler.charAt(index);　
　　　　index++;　
　　　　if　(index　>=　filler.length())　{　
　　　　　　index　=　0;　
　　　　}　
　　　　return　c;　
　　}　
}