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多线程写入同一文件的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。