写一个多线程的java程序以实现Writer(作者)和Reader(读者)共享文件。
有一个文件里保存一篇文章(可以为简单的英文句子或几个单词),Writer可以修改这篇文章(比如往文件里添加新的单词),Reader可以阅读文章。采用多线程实现:Write...
有一个文件里保存一篇文章(可以为简单的英文句子或几个单词),Writer可以修改这篇文章(比如往文件里添加新的单词),Reader可以阅读文章。采用多线程实现:Writer在修改这篇文章时,Reader不可以阅读文章,而Reader阅读文章时Writer也不可以修改文章。
展开
- 你的回答被采纳后将获得:
- 系统奖励15(财富值+成长值)+难题奖励30(财富值+成长值)
1个回答
展开全部
public class Test1 {
public static void main(String args[]) {
//测试两个线程
WriterThread writerThread=new WriterThread();
writerThread.start();
ReaderThread readerThread=new ReaderThread();
readerThread.start();
}
}
//字节输入的线程
class WriterThread extends Thread{
//加上synchronized实现同步,就能达到线程安全
public synchronized void run(){
File file=new File("c:/file.txt");
try {
FileWriter fileWriter = new FileWriter(file,true);//加上true就会在原有的基础上修改,而不会覆盖原来的
fileWriter.write("迦夜云书");
fileWriter.flush();
fileWriter.close();
} catch (IOException e) {
System.out.println("输入内容失败");
e.printStackTrace();
}
}
}
//字节输出的线程
class ReaderThread extends Thread{
public synchronized void run(){
File file=new File("c:/file.txt");
try {
FileReader fileReader = new FileReader(file);
char content[]=new char[1024];
int len=0;
while((len=fileReader.read(content))!=-1){
System.out.println(new String(content, 0,len));
}
fileReader.close();
} catch (Exception e) {
System.out.println("读取内容失败");
e.printStackTrace();
}
}
}
public static void main(String args[]) {
//测试两个线程
WriterThread writerThread=new WriterThread();
writerThread.start();
ReaderThread readerThread=new ReaderThread();
readerThread.start();
}
}
//字节输入的线程
class WriterThread extends Thread{
//加上synchronized实现同步,就能达到线程安全
public synchronized void run(){
File file=new File("c:/file.txt");
try {
FileWriter fileWriter = new FileWriter(file,true);//加上true就会在原有的基础上修改,而不会覆盖原来的
fileWriter.write("迦夜云书");
fileWriter.flush();
fileWriter.close();
} catch (IOException e) {
System.out.println("输入内容失败");
e.printStackTrace();
}
}
}
//字节输出的线程
class ReaderThread extends Thread{
public synchronized void run(){
File file=new File("c:/file.txt");
try {
FileReader fileReader = new FileReader(file);
char content[]=new char[1024];
int len=0;
while((len=fileReader.read(content))!=-1){
System.out.println(new String(content, 0,len));
}
fileReader.close();
} catch (Exception e) {
System.out.println("读取内容失败");
e.printStackTrace();
}
}
}
本回答被提问者和网友采纳
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询