1. package com.thread;
   
2. 
   
3. import java.io.File;
   
4. import java.io.FileNotFoundException;
   
5. import java.io.FileOutputStream;
   
6. import java.io.IOException;
   
7. import java.util.concurrent.ConcurrentLinkedQueue;
   
8. 
   
9. /**
   
10. * 多线程下写文件
    
11. * @author owen.huang
    
12. *
    
13. */
    
14. 
    
15. /**
    
16. * 将要写入文件的数据存入队列中
    
17. */
    
18. class Creater implements Runnable{
    
19. private ConcurrentLinkedQueue<String> queue;
    
20. private String contents;
    
21. public Creater(){}
    
22. public Creater(ConcurrentLinkedQueue<String> queue, String contents){
    
23.   this.queue = queue;
    
24.   this.contents = contents;
    
25. }
    
26. public void run() {
    
27.   try {
    
28.    Thread.sleep(100);
    
29.   } catch (InterruptedException e) {
    
30.    e.printStackTrace();
    
31.   }
    
32.   queue.add(contents);
    
33. }
    
34. }
    
35. 
    
36. /**
    
37. * 将队列中的数据写入到文件
    
38. */
    
39. class DealFile implements Runnable{
    
40. private FileOutputStream out;
    
41. private ConcurrentLinkedQueue<String> queue;
    
42. public DealFile(){}
    
43. public DealFile(FileOutputStream out,ConcurrentLinkedQueue<String> queue){
    
44.   this.out = out;
    
45.   this.queue = queue;
    
46. }
    
47. public void run() {
    
48.   while(true){//循环监听
    
49.    if(!queue.isEmpty()){
    
50.     try {
    
51.      out.write(queue.poll().getBytes());
    
52.     } catch (IOException e) {
    
53.      e.printStackTrace();
    
54.     }
    
55.    }
    
56.    try {
    
57.     Thread.sleep(100);
    
58.    } catch (InterruptedException e) {
    
59.     e.printStackTrace();
    
60.    }
    
61.   }
    
62. }
    
63. }
    
64. 
    
65. /**
    
66. * 测试类
    
67. */
    
68. 
    
69. public class TestMultipleWriteFile {
    
70. public static void main(String[] args) throws FileNotFoundException{
    
71.   FileOutputStream out = new FileOutputStream(new File("F:"+ File.separator +"test.txt"),true);
    
72.   ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<String>();
    
73.    
    
74.   for(int j=0;j<10;j++){
    
75.    new Thread(new Creater(queue,j+"--")).start();//多线程往队列中写入数据
    
76.   }
    
77.   new Thread(new DealFile(out,queue)).start();//监听线程，不断从queue中读数据写入到文件中
    
78. }
    
79. }

复制代码

感觉好厉害的样子

知识有限   看不懂