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{

            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;