java多线程读写同一个文件的代码
2010-01-24 10:48
501 查看
本文提供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);
}
}
本文来自: IT知道网(http://www.itwis.com) 详细出处参考:http://www.itwis.com/html/java/j2se/20080916/2404_2.html
使用简单的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);
}
}
本文来自: IT知道网(http://www.itwis.com) 详细出处参考:http://www.itwis.com/html/java/j2se/20080916/2404_2.html
相关文章推荐
- java向文件中追加内容与读写文件内容源码实例代码
- java多线程读写文件实例
- SAE java应用读写文件(TmpFS和Storage)-----绝世好代码
- HDFS读写文件的java代码
- JAVA多线程读写文件范例
- 关于对同一个txt文件的读写操作Java
- java对同一个文件进行读写操作方法
- 解决多线程读写同一个文件的异常
- java多线程读写文件示例
- 解决多进程或多线程同时读写同一个文件的问题
- 多线程实现对同一个或多个文件的读写操作
- 用java读写properties文件的代码
- java多线程读写文件实例
- Java代码实现对properties文件有序的读写
- java多线程读写文件之文件锁
- LINUX多线程读写同一个文件 加锁
- java文件创建读写代码
- java使用RandomAccessFile类基于指针读写文件实例代码
- JAVA多线程读写文件范例
- Java对xls文件进行读写操作示例代码