您的位置:首页 > 其它

同一线程范围内数据共享

2016-01-16 21:22 330 查看
package com.ygl;

import java.util.HashMap;

import java.util.Map;

import java.util.Random;

public class ThreadScopeShareData {

private static Map<Thread,Integer> threadData=new HashMap<Thread,Integer>();

static class A{

public void getData(){

int data=threadData.get(Thread.currentThread());

System.out.println("A"+Thread.currentThread().getName()+"data:"+data);

}

}

static class B{

public void getData(){

int data=threadData.get(Thread.currentThread());

System.out.println("B"+Thread.currentThread().getName()+"data:"+data);

}

}

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();

System.out.println(Thread.currentThread().getName()+"data:"+data);

threadData.put(Thread.currentThread(), data);

new A().getData();

new B().getData();

}

}).start();

}

}

}

//******************************

package com.ygl;

import java.util.Random;

public class ThreadScopeShareData {

private static ThreadLocal<Integer> threadData=new ThreadLocal<Integer>();

static class A{

public void getData(){

int data=threadData.get();

System.out.println("A"+Thread.currentThread().getName()+"data:"+data);

}

}

static class B{

public void getData(){

int data=threadData.get();

System.out.println("B"+Thread.currentThread().getName()+"data:"+data);

}

}

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();

System.out.println(Thread.currentThread().getName()+"data:"+data);

threadData.set(data);

new A().getData();

new B().getData();

}

}).start();

}

}

}

//*********************************************************

package com.ygl;

import java.util.Random;

public class ThreadScopeShareData {

private static ThreadLocal<Integer> threadData=new ThreadLocal<Integer>();

private static ThreadLocal<MyThreadScopeData> myThreadScopeData=new ThreadLocal<MyThreadScopeData>();

static class A{

public void getData(){

int data=threadData.get();

System.out.println("A"+Thread.currentThread().getName()+"data:"+data);

MyThreadScopeData mydata=MyThreadScopeData.getThreadInstance();

System.out.println(mydata.getAge()+"===="+mydata.getName());

}

}

static class B{

public void getData(){

int data=threadData.get();

System.out.println("B"+Thread.currentThread().getName()+"data:"+data);

MyThreadScopeData mydata=MyThreadScopeData.getThreadInstance();

System.out.println(mydata.getAge()+"===="+mydata.getName());

}

}

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();

System.out.println(Thread.currentThread().getName()+"data:"+data);

threadData.set(data);

MyThreadScopeData.getThreadInstance().setName(Thread.currentThread().getName());//与本线程相关的实例

MyThreadScopeData.getThreadInstance().setAge(data);

new A().getData();

new B().getData();

}

}).start();

}

}

}

class MyThreadScopeData{

private static ThreadLocal<MyThreadScopeData> map=new ThreadLocal<MyThreadScopeData>();

private MyThreadScopeData(){}

public static MyThreadScopeData getThreadInstance(){

MyThreadScopeData instance=map.get();

if(instance ==null){

instance=new MyThreadScopeData();

map.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;

}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: