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{
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)
1
2
3
4
5
具體原因還不知道
api:
java.lang:class threadlocal<t>
單變量
使用threadlocal類型的對象代替上面的map即可
多變量
定義一個對象來封裝多個變量,然後在threadlocal中存儲整個對象
多變量時,最好将threadlocal類放在資料類的内部,資料類采用單例模式,這樣,建立對象和擷取對象都會更友善,同時封裝性更強。
示例代碼:
public class threadlocaltest {
private static threadlocal<integer> threadinger = new threadlocal<>();
new thread(new runnable() {
int data = new random().nextint(100);
threadinger.set(data);
mythreadscopedata.getthreadinstance().setname(thread.currentthread().tostring());
mythreadscopedata.getthreadinstance().setage(data%10);
static class a{
int data = threadinger.get();
mythreadscopedata mythreadscopedata = mythreadscopedata.getthreadinstance();
system.out.println("a from "+mythreadscopedata);
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
public class mutithreadsharedata {
private static mutisharedata mutisharedata = new mutisharedata();
for(int i=0;i<3;i++){
@override
public void run() {
system.out.println(thread.currentthread()+":{j from "+ mutisharedata.getj()+" + to: "+mutisharedata.increment()+"}");
}
}
).start();
system.out.println(thread.currentthread()+":{j from "+ mutisharedata.getj()+" - to: "+mutisharedata.decrement()+"}");
* 将共享資料封裝在另一對象中(操作資料的方法也在該對象完成)
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;