java基础多线程之共享数据
java基础巩固笔记5-多线程之共享数据
线程范围内共享数据
ThreadLocal类
多线程访问共享数据
几种方式
本文主要总结线程共享数据的相关知识,主要包括两方面:一是某个线程内如何共享数据,保证各个线程的数据不交叉;一是多个线程间如何共享数据,保证数据的一致性。
线程范围内共享数据
自己实现的话,是定义一个Map,线程为键,数据为值,表中的每一项即是为每个线程准备的数据,这样在一个线程中数据是一致的。
例子
package com.iot.thread;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
/**
* Created by brian on 2016/2/4.
*/
public class ThreadScopeShareData {
//准备一个哈希表,为每个线程准备数据
private static Map<Thread,Integer> threadData = new HashMap<>();
public static void main(String[] args) {
for(int i=0;i<2;i++){
new Thread(
new Runnable() {
@Override
public void run() {
int data = new Random().nextInt();
threadData.put(Thread.currentThread(),data);
System.out.println(Thread.currentThread()+" put data:"+data);
new A().get();
new B().get();
}
}).start();
}
}
static class A{
public void get(){
int data = threadData.get(Thread.currentThread());
System.out.println("A from "+Thread.currentThread()+" get data "+data);
}
}
static class B{
public void get(){
int data = threadData.get(Thread.currentThread());
System.out.println("B from "+Thread.currentThread()+" get data "+data);
}
}
}
上述代码偶尔会报异常:
Exception in thread "Thread-0" java.lang.NullPointerException
at com.iot.thread.ThreadScopeShareData$A.get(ThreadScopeShareData.java:29)
at com.iot.thread.ThreadScopeShareData$1.run(ThreadScopeShareData.java:21)
at java.lang.Thread.run(Thread.java:745)
具体原因还不知道
ThreadLocal类
API:
java.lang:Class ThreadLocal<T>
单变量
使用ThreadLocal类型的对象代替上面的Map即可
多变量
定义一个对象来封装多个变量,然后在ThreadLocal中存储整个对象
多变量时,最好将ThreadLocal类放在数据类的内部,数据类采用单例模式,这样,新建对象和获取对象都会更方便,同时封装性更强。
示例代码:
package com.iot.thread;
import java.util.Random;
/**
* Created by brian on 2016/2/4.
*/
public class ThreadLocalTest {
private static ThreadLocal<Integer> threadInger = new ThreadLocal<>();
public static void main(String[] args) {
for(int i=0;i<2;i++){
new Thread(new Runnable() {
@Override
public void run() {
int data = new Random().nextInt(100);
threadInger.set(data);
System.out.println(Thread.currentThread()+" put data:"+data);
MyThreadScopeData.getThreadInstance().setName(Thread.currentThread().toString());
MyThreadScopeData.getThreadInstance().setAge(data%10);
new A().get();
new B().get();
}
}).start();
}
}
static class A{
public void get(){
int data = threadInger.get();
System.out.println("A from "+Thread.currentThread()+" get data "+data);
MyThreadScopeData myThreadScopeData = MyThreadScopeData.getThreadInstance();
System.out.println("A from "+myThreadScopeData);
}
}
static class B{
public void get(){
int data = threadInger.get();
System.out.println("B from "+Thread.currentThread()+" get data "+data);
MyThreadScopeData myThreadScopeData = MyThreadScopeData.getThreadInstance();
System.out.println("B from "+myThreadScopeData);
}
}
}
/**
* 将多变量封装起来的数据类
* 单例模式,内置ThreadLocal类型变量
*/
class MyThreadScopeData{
private MyThreadScopeData(){}
private static ThreadLocal<MyThreadScopeData> data = new ThreadLocal<>();
public static MyThreadScopeData getThreadInstance(){
MyThreadScopeData instance = data.get();
if(instance == null){
instance = new MyThreadScopeData();
data.set(instance);
}
return instance;
}
private String name;
private int age;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
@Override
public String toString() {
String reVal = super.toString()+"-{name,age}"+":{"+getName()+","+getAge()+"}";
return reVal;
}
}
多线程访问共享数据
几种方式
线程执行代码相同,使用同一Runnable对象,Runnable对象中有共享数据
线程执行代码不同,将共享数据封装在另一对象中(操作数据的方法也在该对象完成),将这个对象逐一传递给各个Runnable对象。[本质:共享数据的对象作为参数传入Runnable对象]
线程执行代码不同,将Runnable对象作为某一个类的内部类,共享数据作为这个外部类的成员变量(操作数据的方法放在外部类)。[本质:不同内部类共享外部类数据]
结合上两种方式,将共享数据封装在另一对象中(操作数据的方法也在该对象完成),该对象作为这个外部类的成员变量,将Runnable对象作为内部类
最后一种方式的示例:
设计5个线程,其中三个线程每次对j增加1,另外两个线程对j每次减少1
package com.iot.thread;
/**
* Created by brian on 2016/2/4.
*/
public class MutiThreadShareData {
private static MutiShareData mutiShareData = new MutiShareData();
public static void main(String[] args) {
for(int i=0;i<3;i++){
new Thread(
new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread()+":{j from "+ mutiShareData.getJ()+" + to: "+mutiShareData.increment()+"}");
}
}
).start();
}
for(int i=0;i<2;i++){
new Thread(
new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread()+":{j from "+ mutiShareData.getJ()+" - to: "+mutiShareData.decrement()+"}");
}
}
).start();
}
}
}
/**
* 将共享数据封装在另一对象中(操作数据的方法也在该对象完成)
*/
class MutiShareData{
private int j = 0;
public synchronized int increment(){
return ++j;
}
public synchronized int decrement(){
return --j;
}
public synchronized int getJ() {
return j;
}
public synchronized void setJ(int j) {
this.j = j;
}
}
- phalcon-入门篇7(Model层基础使用)
- Sharding-JDBC 源码分析 —— SQL 解析(二)之SQL解析
- zephir-(1)开篇介绍
- phalcon-入门篇6(控制器)
- phalcon-入门篇5(请求与返回)
- phalcon-入门篇2(HelloWord与PhalconTools)
- 数据库中间件 Sharding-JDBC 源码分析 —— SQL 解析(一)之语法解析
- phalcon-入门篇4(log日志和session缓存)
- zephir-(5)类型
- zephir-(10)内置函数
- zephir-(9)类和对象2
- 深度学习中的动手实践:在CIFAR-10上进行图像分类
- 数据库中间件 MyCAT源码分析 —— XA分布式事务
- [喵咪Golang(1)]Go语言开篇
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- [ 利器篇 ] - Microsoft Surface Pro 系列安装 Ubuntu 16.04 系统
- 如何优雅的打造 All-in One 仓库
- matplotlib绘图教程:设置标签与图例
- 企业是如何从头开发一个商业项目的?
- 基于Haproxy的高可用实战
- 组复制常规操作-分布式恢复 | 全方位认识 MySQL 8.0 Group Replication
- 赞!7000 字学习笔记,MySQL 从入到放弃
- 面试官问我Volatile的原理?从操作系统层面的设计怼回去!
- 设计原则之单一职责
- 设计原则之开闭原则
- SpringBoot执行跨域处理
- SpringBoot对全局异常的处理封装
- 自定义springboot-starter揭秘自动配置骚操作
- 【大厂面试题】Redis中是如何实现分布式锁的?
- 最近公司招人,研发组商量了下,暂时定下这么多java面试题!