8个答案 按时间排序 按投票排序

0 0

采纳的答案

如果有一个线程正在读文件，这时又有另个一个线程想来写这个文件 会报错吗?
答案是不会。
请运行以下的代码 就知道了

package org.sse.test;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;

public class IO {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		new IO().test();
	}

	private void test() {
		ReadThead rt = new ReadThead();
		Thread t1 = new Thread(rt, "ReadThead");
		WriteThead wt = new WriteThead();
		Thread t2 = new Thread(wt, "WriteThead");
		t1.start();
		t2.start();
	}

	protected class WriteThead implements Runnable {

		@Override
		public void run() {
			try {
				File f = new File("D:\\A.txt");
				FileOutputStream fos = new FileOutputStream(f);
				byte[] b = "hello".getBytes();
				while (true) {
					fos.write(b);
					fos.flush();
					Thread.sleep(1000);
				}
			} catch (FileNotFoundException e) {
				e.printStackTrace();
			} catch (IOException e) {
				e.printStackTrace();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}

		}

	}

	protected class ReadThead implements Runnable {

		@Override
		public void run() {
			try {
				File f = new File("D:\\A.txt");
				FileInputStream fis = new FileInputStream(f);
				int readData;
				while (true) {
					readData = fis.read();
					if (readData == -1) {
						Thread.sleep(1000);
					} else {
						System.out.println(readData);
					}
				}
			} catch (FileNotFoundException e) {
				e.printStackTrace();
			} catch (IOException e) {
				e.printStackTrace();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}

	}
}

2013年3月08日 10:35

goodscript
30
0 0 3

• 添加评论

0 0

同时读是没有任何问题的,直接读就可以了
至于同时写,因为有锁,不过要实现也是可以的
我的大体思想是这样的:比如有A和B两个线程,首先A把0-100的字节写进去,B开始读101-200的字节并存入一个缓存中,然后A退出开始读201-300之间的字节,B将缓存写入,如此循环就可以实现多线程读写了
本人的一点愚见,希望能帮到你

2013年3月07日 11:37

lin358
4
0 0 14

• 添加评论

0 0

亲，这个问题google大把答案还有现成的代码哦。亲！

2013年3月06日 18:30

freezingsky
159
1 1 16

• 添加评论

0 0

nio 就是非阻塞，读从来都没有加锁的啊

2013年3月06日 17:46

houyujiangjun
4
0 1 6

• 添加评论

0 0

多个线程同时写都是可以的，你去看看java.nio.channels.FileChannel

2013年3月06日 17:32

OpenMind
704
0 1 13

• 添加评论

0 0

写加锁 读不加锁的

2013年3月06日 14:46

nestnall
30
0 0 2

• 添加评论

0 0

本文提供java多线程分别定时读写同一个文件的样例，其中两个线程，一个每分钟写入当前时间到指定文件，另一个线程读出每分钟新写的内容。
使用简单的Thread.sleep技术实现定时
package test.thread;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.util.Date;
/**
* 多线程读写同一个文件的样例。
*/
public class ThreadReadWrite {
  public static void main(String[] args) {
    new ThreadWrite().start();
    try {
      Thread.sleep(2000); // 休眠，以免那面还有写好
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    new ThreadRead().start();
  }
}
class ThreadWrite extends Thread {
  File file = new File("test.txt");
  @Override
  public void run() {
    try {
      while (true) {
        FileWriter out = new FileWriter(file, true);// 追加写入
        out.write(new Date() + "/n");
        out.flush();
        out.close();
        Thread.sleep(3000); // 我这里间隔改成3秒，方便测试
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}
class ThreadRead extends Thread {
  File file = new File("test.txt");
  @Override
  public void run() {
    try {
      BufferedReader reader = new BufferedReader(new FileReader(file));
      while (true) {
        System.out.println(reader.readLine());
        Thread.sleep(3000); // 我这里间隔改成3秒，方便测试
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
  }
}

如果真的要求严格，应该用Timer继续比较精确的控制。
package test.thread;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
/**
* 使用Timer定时器进行同一文件的读写。
*/
public class ThreadReadWriteTimer {
  static File file = new File("test.txt");
  public static void main(String[] args) {
    Timer timer = new Timer();
    timer.scheduleAtFixedRate(new TimerTask() {
      @Override
      public void run() {
        FileWriter out;
        try {
          out = new FileWriter(file, true);
          // 追加写入
          out.write(new Date() + "/n");
          out.flush();
          out.close();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }, 0, 3000);
    timer.scheduleAtFixedRate(new TimerTask() {
      BufferedReader reader = null;
      {
        try {
          reader = new BufferedReader(new FileReader(file));
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
      @Override
      public void run() {
        try {
          System.out.println(reader.readLine());
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }, 1000, 3000);
  }
}

2013年3月06日 14:24

李明星
13
0 0 8

• 添加评论

0 0

好像 可以吧

2013年3月06日 14:23

李明星
13
0 0 8

• 添加评论