欢迎您光临本小站。希望您在这里可以找到自己想要的信息。。。

张孝祥老师-java并发编程听课笔记(三)

java water 1250℃ 0评论

第六讲

ThreadLocal实现线程范围内的共享

 

ThreadLocal相当于一个哈希

public class ThreadLocalTest{

 

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

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

System.out.println(Thread.currentThread().getName() + “has put data : ” + data);

x.set(data); //存到当前线程中

new A().get();

new B().get();

}

}).start();

}

}

static class A{

         public void get(){

                   int data = x.get();

System.out.println(“A from ” + Thread.currentThread().getName() + “get data : ” + data);

}

}

static class B{

public void get(){

int data = x.get();

System.out.println(“A from ” + Thread.currentThread().getName() + “get data : ” + data);

}

}

}

//如果线程中有多个变量需要线程内共享

需要把这多个变量封装成一个实体

class MyThreadScopeData{

         private String name;

         private int age;

         //setget方法省略

}

定义一个ThreadLocal

private static ThreadLocal<MyThreadScopeData> myThreadScopeData 变量

然后new MythreadScopeData对象,然后属性赋值

把这个对象setThreadLocal里面

取就是ThreadLocal调用get获取对象

 

这样思路特别麻烦,混乱。有一种优雅的方式解决

class MyThreadScopeData{

         private MyThreadScopeData(){};

         //饱汉模式(一)

         private static MyThreadScopeData instance = new MyThreadScopeDAta();

         public static MyThreadScopeData getInstance(){

         return instance;

}

//饥饿模式(二)

private static MyThreadScopeData instance = null;

public static synchronized MyThreadScopeData getInstance(){

         if (instance == null){

                   instance = new MyThreadScopeData();

}

return instance;

}

 

//优雅的方法实现

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

public static MyThreadScopeData getInstance(){

         MyThreadScopeData instance = map.get();

         if (instance == null){

                   instance = new MythreadScopeData();

                   map.set(instance);

}

return instance;

}

         private String name;

         private int age;

         //setget方法省略

}

这种方式和单例很相似

存数据

MyThreadScopeData.getInstance().setName(“name” + data);

MyThreadScopeData.getInstance().setName(“age” + data);

获取数据

MyThreadScopeData.getInstance().getInstance().getName;

每一个线程来了(struts2请求),就会有个容器对象。

ThreadLocal.clear();

ThreadLocal实际上就是一个map,时间久了可能需要清空,垃圾回收自动释放。

注册监听器,回调,线程什么时候退出,通知一下。

怎么得到线程结束的通知事件

 

 

第七讲

 

多个线程之间共享变量

设计4个线程,其中两个线程每次对j增加1,另外两个线程j每次减1,写出程序

100张门票,5个窗口共享买票

public class MultiThreadShareData{

         public static void main(String[] args){

                   //第一种方案

                   ShareData1 data1 = new ShareData1();

                   new Thread(data1).start();

                   new Thread(data1).start();

}

}

 

class ShareData1 implements Runnable{

         /**

          *(第一种方案)

         private int count = 100;

         @Override

         public void run(){

                   while(true){

                            count–;

}

} */

         private int j = 0;

         public synchronized void increment(){

                   j++;

}

public synchronized void dec(){

         j–;

}

}

 

如果每个线程执行的代码相同,可以使用同一个Runnable对象,这个Runnable对象中有那个共享数据,例如,卖票系统就可以这么做(第一种方案)

 

如果每个线程执行的代码不同,这时候需要用不同的Runnable对象,有如下两种方式来实现这些Runnable对象之间的数据共享

1.       将共享数据封装在另外一个对象中,然后将这个对象逐一传递给各个Runnable对象。每个线程对共享数据的操作方法也分配到那个对象身上去完成,这样容易实现针对该数据进行的各个操作的互斥和通信

2.       将这些Runnable对象作为某一个类中的内部类,共享数据作为一个外部类中的成员变量,每个线程对共享数据的操作方法也分配给外部类,以便实现对共享数据进行的各个操作的互斥和通信,作为内部类的各个Runnable对象调用外部类的这些方法

 

第八讲

 

java5中的线程并发库

java.util.concurrent包下面的

java.util.concurrent.atomic

java.util.concurrent.locks

 

原子性操作

可以对基本数据,对数组中的基本数据,对类中的基本数据等进行操作

AtomicInteger类自动实现线程同步(对整数的操作),对象对多个线程访问才需要用

atomicIntegerArray;

AtomicIntegerFieldUpdater, 方法newUpdater(Class<U> tclass, String feild)

转载请注明:学时网 » 张孝祥老师-java并发编程听课笔记(三)

喜欢 (0)or分享 (0)

您必须 登录 才能发表评论!