package Thread;

import java.io.*;

import java.text.SimpleDateFormat;

import java.util.Date;

/**

* Created by szh on 2017/3/27.

* 测试在多线程的情况下普通IO的读写情况

* 在未加入flush方法的时候一直写不到10000，需要主要每次写入

*/

public class FileThread {

public static void main(String args[]) throws InterruptedException, IOException {

FileInOut fileInOut1 =new FileInOut("D:\\disk\\qqq.txt","第一个");

FileInOut fileInOut2 =new FileInOut("D:\\disk\\qqq.txt","第二个");

new Thread(fileInOut1).start();

new Thread(fileInOut2).start();

Thread.sleep(5000);

System.out.println("已经推出");

// wr();

}

public static void wr() throws IOException {

int t = 0;

File file = new File("D:\\disk\\qqq.txt");

Writer writer = new FileWriter(file);

while (t < 10000) {

writer.write(t + Thread.currentThread().getName());

writer.flush();

t++;

}

writer.close();

}

}

class FileInOut extends Thread {

String path;

String content;

public FileInOut(String path, String content) {

this.path = path;

this.content = content;

}

@Override

public void run() {

try {

synchronized (this) {

reou(this.path, this.content);

}

} catch (IOException e) {

e.printStackTrace();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

public synchronized void reou(String path, String content) throws IOException, InterruptedException {

Writer writer = new FileWriter(new File(path),true);

// String s1="he";

// writer.write(s1+content);

SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

System.out.println(simpleDateFormat.format(new Date()) + "-----------" + Thread.currentThread().getName());

int i = 0;

StringBuffer sb = new StringBuffer();

while (i < 10000) {

synchronized (writer) {

sb.append("0");

writer.write(i + Thread.currentThread().getName()+"\r\n");

writer.flush();

i++;

}

}

System.out.println(i);

System.out.println(sb.toString().length() + "sb的值");

System.out.println(simpleDateFormat.format(new Date()) + "-----------" + Thread.currentThread().getName());

// String s2="llo"+content;

// writer.write(s2);

// writer.close();

}

}