如何加读写锁 - ITeye问答

0 0

如何加读写锁0

1.WriteMethod是个写数据到文件的方法

package test;

import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.UnsupportedEncodingException;

public class WriteMethod {
	
	public static void createCsvFile(String filePath,String data){
		FileOutputStream fos = null;
		OutputStreamWriter out = null;
		try {
			fos = new FileOutputStream(filePath);
			out = new OutputStreamWriter(fos,"UTF-8");
			out.write(data);
		} catch (FileNotFoundException e) {
			e.getMessage();
		} catch (UnsupportedEncodingException e) {
			e.getMessage();
		} catch (IOException e) {
			e.getMessage();
		} finally{
			try {
				if(out!=null){
					out.close();
				}
				if(fos!=null){
					fos.close();
				}
			} catch (IOException e) {
				e.getMessage();
			}
		}
	}
}

2.ReadFile是一个读文件的方法

package test;

import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.Reader;
import java.io.UnsupportedEncodingException;

public class ReadFile{
	
	public static void readCsvFile(String filePath){
		Reader is = null;
		BufferedReader br = null;
		try {
			is = new FileReader(filePath);
			br = new BufferedReader(is);
			System.out.println(br.readLine());
		} catch (FileNotFoundException e) {
			e.getMessage();
		} catch (UnsupportedEncodingException e) {
			e.getMessage();
		} catch (IOException e) {
			e.getMessage();
		} finally{
			try {
				if(br!=null){
					br.close();
				}
				if(is!=null){
					is.close();
				}
			} catch (IOException e) {
				e.getMessage();
			}
		}
	}
}

3.TestWriteThread是一个写的线程类，不停的在调WriteMethod这个类

package test;

public class TestWriteThread extends Thread{
	private static boolean flag = true;
	public void run(){
		while(flag){
			dome();
		}
	}
	
	public void dome(){
		write();
	}
	
	public void write(){
		WriteMethod.createCsvFile("D:\\abc.txt","a");
	}
}

4.Test起一个写的线程，不停的在写

package test;

public class Test {
	public static void main(String[] args) throws Exception{
		TestWriteThread tw = new TestWriteThread();
		tw.start();
	}
}

5.Test2不停的再读，注意：但是它不是线程类！！！

package test;

public class Test2 {
	public static void main(String[] args) {
		while(true){
			ReadFile.readCsvFile("D:\\abc.txt");
		}
	}
}

现在当先运行第四步再运行第五步，即不停的在写时也不停的在读，就会出现读到null值，那么该如何加锁，从而不出现null？？？

Java IO流读写锁

2013年8月06日 22:16

QuarterLifeForJava
69
0 1 11

test.zip (6.4 KB)
下载次数: 2

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

0 0

有点类似unix里面 tail命令的方式

改变一下代码读文件的方式就可以了，不用加锁

大概的代码形如：

 boolean running=true;
while (running) {
			try {
				line = reader.readLine();
				if (line != null) {
					if (showLineNo) {
						lineNo++;
						System.out.printf("%5d%s%s", lineNo, ": ", line);
						System.out.println();
					} else
						System.out.println(line);
				}
				Thread.sleep(50);
			} catch (IOException e) {
				handleIOException();
			} catch (InterruptedException e) {
				stop();
			}
		}

这是我自己以前实现tail时编写的代码的片段

2013年8月07日 15:35