Java多线程之详解ThreadLocal类(一)
2017-06-21 15:36
507 查看
ThreadLocal类是用来创建和管理线程的本地存储的类。线程的本地存储可以为相同变量的每个不同线程都创建不同的存储,根除了线程对变量的共享,从而防止多线程任务在共享资源上发生冲突。我们先看下列代码:
我们在构造ThreadLocal的时候重写了它的initialValue方法,这个方法是ThreadLocal的初始化方法,线程在调用get方法时如果发现得到的值为null则会调用本方法,通过查阅jdk我们可以发现,ThreadLocal类中只有initialValue,get,set和remove方法,这几个方法我们看名字就能够知道它们的作用。上述代码的执行结果如下图所示:
#3:9
#1:6
#0:4
#2:2
#4:2
#0:5
#2:3
#4:3
#0:6
#2:4
为了方便区分,我们给了每个线程一个final标识的id,通过查看结果我们发现结果确实和我们猜想的一样,每个线程只维护自有的属性。另外我在网上查找资料时发现有些人说ThreadLocal不能使用原子类,特意去写代码试了试,代码如下:
运行结果如下:
#3:6
#1:10
#3:7
#1:11
#3:8
#1:12
#3:9
#1:13
#3:10
事实证明,ThreadLocal是可以使用原子类的。
public class ThreadLocalTest { private static ThreadLocal<Integer> value = new ThreadLocal<Integer>(){ private Random rand = new Random(47); protected synchronized Integer initialValue(){ return rand.nextInt(10000); } }; public static void increment(){ value.set(value.get()+1); } public static int get(){ return value.get(); } public static void main(String[] args) throws InterruptedException { ExecutorService exe= Executors.newCachedThreadPool(); for(int i = 0;i < 5; i++){ exe.execute(new Accessor(i)); } TimeUnit.SECONDS.sleep(1); exe.shutdown(); } } class Accessor implements Runnable{ private final int id; public Accessor(int idn){ this.id = idn; } @Override public void run() { while(!Thread.currentThread().isInterrupted()){ ThreadLocalTest.increment(); System.out.println(this); Thread.yield(); } } public String toString(){ return "#"+id+":"+ThreadLocalTest.get(); } }
我们在构造ThreadLocal的时候重写了它的initialValue方法,这个方法是ThreadLocal的初始化方法,线程在调用get方法时如果发现得到的值为null则会调用本方法,通过查阅jdk我们可以发现,ThreadLocal类中只有initialValue,get,set和remove方法,这几个方法我们看名字就能够知道它们的作用。上述代码的执行结果如下图所示:
#3:9
#1:6
#0:4
#2:2
#4:2
#0:5
#2:3
#4:3
#0:6
#2:4
为了方便区分,我们给了每个线程一个final标识的id,通过查看结果我们发现结果确实和我们猜想的一样,每个线程只维护自有的属性。另外我在网上查找资料时发现有些人说ThreadLocal不能使用原子类,特意去写代码试了试,代码如下:
private static ThreadLocal<AtomicInteger> value = new ThreadLocal<AtomicInteger>(){ private Random rand = new Random(47); protected synchronized AtomicInteger initialValue(){ return new AtomicInteger(rand.nextInt(5)); } }; public static void increment(){ AtomicInteger ai = value.get(); int c = ai.get()+1; ai.set(c); value.set(ai); } public static int get(){ return value.get().get(); } public static void main(String[] args) throws InterruptedException { ExecutorService exe= Executors.newCachedThreadPool(); for(int i = 0;i < 5; i++){ exe.execute(new Accessors(i)); } TimeUnit.SECONDS.sleep(1); exe.shutdown(); } } class Accessors implements Runnable{ private final int id; public Accessors(int idn){ this.id = idn; } @Override public void run() { while(!Thread.currentThread().isInterrupted()){ ThreadLocalTest.increment(); System.out.println(this); Thread.yield(); } } public String toString(){ return "#"+id+":"+ThreadLocalTest.get(); } }
运行结果如下:
#3:6
#1:10
#3:7
#1:11
#3:8
#1:12
#3:9
#1:13
#3:10
事实证明,ThreadLocal是可以使用原子类的。
相关文章推荐
- Java多线程之详解ThreadLocal类(一)
- (三) Java多线程详解之线程范围内共享变量及ThreadLocal类使用
- Java多线程之详解ThreadLocal类(一)
- JAVA多线程系列--ThreadLocal详解
- Java多线程之详解ThreadLocal类(一)
- java高级进阶关于java多线程的应用 ThreadLocal多线程实例详解
- java多线程模式ThreadLocal原理简述及其使用详解
- Java多线程之详解ThreadLocal类(一)
- java多线程详解(5)-Threadlocal用法
- Java多线程之详解ThreadLocal类(一)
- java核心知识点学习----多线程间的数据共享和对象独立,ThreadLocal详解
- Java多线程之详解ThreadLocal类(一)
- Java多线程之详解ThreadLocal类(一)
- java高级进阶关于java多线程的应用 ThreadLocal多线程实例详解
- java多线程模式ThreadLocal原理简述及其使用详解
- Java多线程之详解ThreadLocal类(一)
- java多线程详解
- Java多线程详解(二)
- Java Socket多线程编程、通信模型及socket协议详解
- Java多线程下 ThreadLocal 的应用实例