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

Thread-Specific-Storage[线程保管箱]

一:Thread-Specific Storage的参与者
--->记录日志的线程（ClientThread）
--->负责获取不同线程记录日志(Log)
--->负责将日志写入文件的类（TsLog）

       

二:Thread-Specific Storage模式什么时候使用
--->当每个线程必须有自己的独有信息时，可以将该信息放入线程保管箱ThreadLocal


三：Thread-Specific Storage思考
--->放置线程特有信息的地方
        （1）线程外--->线程的保管箱ThreadLocal
           (2)    线程内-->线程体的局部变量

--->多线程处理共有数据，存在共享互斥
--->共享互斥会降低性能，所以要尽量将共享互斥的范围缩小
--->线程的性能在于线程代码的实现

四进阶说明        
--->

记录日志的行为类

package com.yeepay.sxf.thread11;

import java.io.FileWriter;
import java.io.PrintWriter;

/**
 * 日志类
 * @author sxf
 *
 */
public class TsLog {
    //写日志对象
    private PrintWriter printWriter=null;
    
    //构造器
    public TsLog(String fileName){
        try {
            printWriter=new PrintWriter(new FileWriter(fileName));
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    //添加一条日志
    public void addLogStr(String logstr){
        printWriter.print(logstr);
    }
    
    //关闭输出流
    public void closeLog(){
        printWriter.close();
    }
}

代理不同线程的记录日志的对象

package com.yeepay.sxf.thread11;


/**
 * 不同线程分发不同的日志实例
 * @author sxf
 *
 */
public class Log {
    //线程的保管箱集合
    private static final ThreadLocal tsLongConteint=new ThreadLocal();

    public static void printLogStr(String logStr){
        TsLog log=getTslog();
        log.addLogStr(logStr);
    }
    //获取当前线程的保管箱
    public static TsLog getTslog(){
        //从线程保管箱中拿去当前线程的TsLog
        TsLog lg=(TsLog) tsLongConteint.get();
        //如果不存在，创建新的TsLog
        if(lg==null){
            lg=new TsLog("/usr/war/"+Thread.currentThread().getName()+"-log.txt");
            tsLongConteint.set(lg);
        }
        return lg;
    }
    //关闭log对象的流
    public static void  closeTsLog(){
        getTslog().closeLog();
    }
}

记录日志的线程类

package com.yeepay.sxf.thread11;
/**
 * 记录日志的线程
 * @author sxf
 *
 */
public class ClientThreaad  implements Runnable{
    
    public ClientThreaad() {

    }
    
    
    @Override
    public void run() {
        for (int i = 0; i <10; i++) {
            Log.printLogStr(Thread.currentThread().getName()+i);
            System.out.println("ClientThreaad.run()==>"+Thread.currentThread().getName()+i);
        }
        Log.closeTsLog();
    }
    

}

测试类

package com.yeepay.sxf.thread11;
/**
 * 测试类
 * @author sxf
 *
 */
public class Test {
    
    
    public static void main(String[] args) {
        //开启三个线程，产生3个文件,三个线程自己记录自己的日志
        new Thread(new ClientThreaad()).start();
        new Thread(new ClientThreaad()).start();
        new Thread(new ClientThreaad()).start();
    }

}