多线程程序设计学习（12）Thread-soecific storage pattern

 1 package com.yeepay.sxf.thread11;
 2 
 3 import java.io.FileWriter;
 4 import java.io.PrintWriter;
 5 
 6 /**
 7  * 日志类
 8  * @author sxf
 9  *
10  */
11 public class TsLog {
12     //写日志对象
13     private PrintWriter printWriter=null;
14     
15     //构造器
16     public TsLog(String fileName){
17         try {
18             printWriter=new PrintWriter(new FileWriter(fileName));
19         } catch (Exception e) {
20             // TODO Auto-generated catch block
21             e.printStackTrace();
22         }
23     }
24     
25     //添加一条日志
26     public void addLogStr(String logstr){
27         printWriter.print(logstr);
28     }
29     
30     //关闭输出流
31     public void closeLog(){
32         printWriter.close();
33     }
34 }

 1 package com.yeepay.sxf.thread11;
 2 
 3 
 4 /**
 5  * 不同线程分发不同的日志实例
 6  * @author sxf
 7  *
 8  */
 9 public class Log {
10     //线程的保管箱集合
11     private static final ThreadLocal tsLongConteint=new ThreadLocal();
12 
13     public static void printLogStr(String logStr){
14         TsLog log=getTslog();
15         log.addLogStr(logStr);
16     }
17     //获取当前线程的保管箱
18     public static TsLog getTslog(){
19         //从线程保管箱中拿去当前线程的TsLog
20         TsLog lg=(TsLog) tsLongConteint.get();
21         //如果不存在，创建新的TsLog
22         if(lg==null){
23             lg=new TsLog("/usr/war/"+Thread.currentThread().getName()+"-log.txt");
24             tsLongConteint.set(lg);
25         }
26         return lg;
27     }
28     //关闭log对象的流
29     public static void  closeTsLog(){
30         getTslog().closeLog();
31     }
32 }

 1 package com.yeepay.sxf.thread11;
 2 /**
 3  * 记录日志的线程
 4  * @author sxf
 5  *
 6  */
 7 public class ClientThreaad  implements Runnable{
 8     
 9     public ClientThreaad() {
10 
11     }
12     
13     
14     @Override
15     public void run() {
16         for (int i = 0; i <10; i++) {
17             Log.printLogStr(Thread.currentThread().getName()+i);
18             System.out.println("ClientThreaad.run()==>"+Thread.currentThread().getName()+i);
19         }
20         Log.closeTsLog();
21     }
22     
23 
24 }

 1 package com.yeepay.sxf.thread11;
 2 /**
 3  * 测试类
 4  * @author sxf
 5  *
 6  */
 7 public class Test {
 8     
 9     
10     public static void main(String[] args) {
11         //开启三个线程，产生3个文件,三个线程自己记录自己的日志
12         new Thread(new ClientThreaad()).start();
13         new Thread(new ClientThreaad()).start();
14         new Thread(new ClientThreaad()).start();
15     }
16 
17 }