五:java中线程范围内共享变量--Map实现
2016-03-16 15:50
561 查看
前记
上一篇温习的是java中传统的线程的同步与通信,这次来温习线程范围内的共享变量场景及代码
首先我们有一种这样的场景,我在一个流程当中的各步骤中从每个线程中拿到的数据是一致的,每个线程之间的可能是不一样的,也就是要拿到和线程有关的变量数据。下面是我们初始想到的代码,但是结果却和我们的需求有点出入
package com.web.thread; import java.util.Random; /********************************************************************************* //* Copyright (C) 2015 Pingan (PA). All Rights Reserved. //* //* Filename: ThreadScopeShareData.java //* Revision: 1.0 //* Author: <gao yunqi> //* Created On: 2016年3月16日 //* Modified by: //* Modified On: //* //* Description: <线程范围内的共享变量问题代码> /********************************************************************************/ public class ThreadScopeShareData { private static int data = 0; public static void main(String[] args) { for (int i = 0; i < 10; i++) { new Thread(new Runnable() { @Override public void run() { synchronized (ThreadScopeShareData.class) { data = new Random().nextInt(); } System.out.println(Thread.currentThread().getName() + " has put data " + data); new Step1().getData(); new Step2().getData(); } }).start(); } } static class Step1{ public void getData(){ System.out.println("Step1 from " + Thread.currentThread().getName() + " get data " + data); } } static class Step2{ public void getData(){ System.out.println("Step2 from " + Thread.currentThread().getName() + " get data " + data); } } }
通过观察结果我们发现,最终取到的都是同一个值,下面我们来解决这个问题
package com.web.thread; import java.util.HashMap; import java.util.Map; import java.util.Random; /********************************************************************************* //* Copyright (C) 2015 Pingan (PA). All Rights Reserved. //* //* Filename: ThreadScopeShareData.java //* Revision: 1.0 //* Author: <gao yunqi> //* Created On: 2016年3月16日 //* Modified by: //* Modified On: //* //* Description: <线程范围内的共享变量问题代码> /********************************************************************************/ public class ThreadScopeShareData { private static int data = 0; //定义一个存储线程相关数据的Map private static Map<Thread,Integer> dataMap = new HashMap<Thread,Integer>(); public static void main(String[] args) { for (int i = 0; i < 3; i++) { new Thread(new Runnable() { @Override public void run() { synchronized (ThreadScopeShareData.class) { data = new Random().nextInt(); dataMap.put(Thread.currentThread(), data); } System.out.println(Thread.currentThread().getName() + " has put data " + dataMap.get(Thread.currentThread())); new Step1().getData(); new Step2().getData(); } }).start(); } } static class Step1{ public void getData(){ System.out.println("Step1 from " + Thread.currentThread().getName() + " get data " + dataMap.get(Thread.currentThread())); } } static class Step2{ public void getData(){ System.out.println("Step2 from " + Thread.currentThread().getName() + " get data " + dataMap.get(Thread.currentThread())); } } }
将代码改善为如上所示,发现达到了我们的目的,线程内共享,线程外独立。
相关文章推荐
- 浅析Java中的final关键字
- Java和C#中的自定义元数据
- Spring事务配置的五种方式
- 使用eclipse导出jar包
- Java反射使用技巧
- JAVA CAS原理深度分析
- Java解析xml的主要解析器: SAX和DOM的选择
- eclipse打jar包
- 2016蓝桥杯假期任务之《比酒量》
- Eclipse,hadoop2.7.2 hadoop-eclipse-plugin.jar的制作
- java类ByteArrayOutputStream的toString()方法使用
- Java中实际上有四种强度不同的引用
- Java并发编程:线程间协作的两种方式:wait、notify、notifyAll和Condition
- 注定了Java客户端不利于推向市场
- Java并发编程:Timer和TimerTask(转载)
- 关于一些基础的Java问题的解答(二)
- Java并发编程:Callable、Future和FutureTask
- java annotation与AOP点滴积累
- Java数据类型(一)
- Java中的List接口