java多线程流式写入文件夹_java多线程写入同一文件
1.[代碼][Java]代碼
package com.thread;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.concurrent.ConcurrentLinkedQueue;
/**
* 多線程下寫文件
* @author owen.huang
*
*/
/**
* 將要寫入文件的數據存入隊列中
*/
class Creater implements Runnable{
private ConcurrentLinkedQueue queue;
private String contents;
public Creater(){}
public Creater(ConcurrentLinkedQueue queue, String contents){
this.queue = queue;
this.contents = contents;
}
public void run() {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
queue.add(contents);
}
}
/**
* 將隊列中的數據寫入到文件
*/
class DealFile implements Runnable{
private FileOutputStream out;
private ConcurrentLinkedQueue queue;
public DealFile(){}
public DealFile(FileOutputStream out,ConcurrentLinkedQueue queue){
this.out = out;
this.queue = queue;
}
public void run() {
while(true){//循環監聽
if(!queue.isEmpty()){
try {
out.write(queue.poll().getBytes());
} catch (IOException e) {
e.printStackTrace();
}
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
/**
* 測試類
*/
public class TestMultipleWriteFile {
public static void main(String[] args) throws FileNotFoundException{
FileOutputStream out = new FileOutputStream(new File("F:"+ File.separator +"test.txt"),true);
ConcurrentLinkedQueue queue = new ConcurrentLinkedQueue();
for(int j=0;j<10;j++){
new Thread(new Creater(queue,j+"--")).start();//多線程往隊列中寫入數據
}
new Thread(new DealFile(out,queue)).start();//監聽線程，不斷從queue中讀數據寫入到文件中
}
}
總結
以上是生活随笔為你收集整理的java多线程流式写入文件夹_java多线程写入同一文件的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Java注释 link_Java 文档注
- 下一篇： layui分页limit不显示_【图片】