ThreadLocal_写给自己看的

1.提供了保存线程的功能可以方便对象的参数传递
2.每个线程一个副本并且互不干扰

可以在线程的run方法中使用ThreadLocal进行set(Thread);

//调用端的入口

具体的类
MyThread类

package com.qbsea.knowledge.threadlocal;
public class MyThread implements Runnable {
	@Override
	public void run() {
		System.out.println("这里实现MyThread类的业务方法=");
	}
}

threadLocal负责收集线程的类

package com.qbsea.knowledge.threadlocal;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Executor;

public class MyExecutor implements Executor {
	private ThreadLocal<List<Runnable>> threadLocal = new ThreadLocal<List<Runnable>>();
	@Override
	public void execute(Runnable command) {
		//将Runnable 放入到threadLocal中
		if(threadLocal.get()==null) {
			List<Runnable> list =new ArrayList<>();
			list.add(command);
			threadLocal.set(list);
		}else {
			threadLocal.get().add(command);
		}
		
	}
	
	public void executeReal() {
		List<Runnable> list = threadLocal.get();
		for (Runnable runnable : list) {
			System.out.println("runnable="+runnable.getClass());
			runnable.run();
		}
	}

}

main主函数的执行入口

package com.qbsea.knowledge.threadlocal;

public class MainTest {

	public static void main(String[] args) {
		MyThread mythread1 = new MyThread();
		MyThread mythread2 = new MyThread();
		MyExecutor myExecutor = new MyExecutor();
		myExecutor.execute(mythread1); //收集到ThreadLocal;
		myExecutor.execute(mythread2); //收集到ThreadLocal;
		myExecutor.executeReal();
	}

}

ThreadLocal_写给自己看的

猜你喜欢