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<String> queue;
private String contents;
public Creater(){}
public Creater(ConcurrentLinkedQueue<String> 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<String> queue;
public DealFile(){}
public DealFile(FileOutputStream out,ConcurrentLinkedQueue<String> 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 {http://www.huiyi8.com/jiaoben/
Thread.sleep(100);javascript特效
} 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<String> queue = new ConcurrentLinkedQueue<String>();
for(int j=0;j<10;j++){
new Thread(new Creater(queue,j+"--")).start();//多線程往隊列中寫入數據
new Thread(new DealFile(out,queue)).start();//監聽線程，不斷從queue中讀數據寫入到文件中