java并发编程基础——线程相关的类

线程相关类

java还为线程安全提供了一些工具类。

一、ThreadLocal类(Thread Local Variable)

ThreadLocal类，是线程局部变量的意思。功用非常简单，就是为每一个使用该变量的线程提供一个变量值的副本，使没一个线程都可以独立的改变自己的副本，而不会和其他副本冲突。

ThreadLocal提供了3个public方法

T get()；返回此线程局部变量中当前线程副本中的值

void remove()：删除此线程局部变量中当前线程的值

void set(T value):设置此线程局部变量中当前线程副本中的值

ThreadLocal也是为了解决多线程中对同一变量访问的冲突。普通的同步机制中是通过对象加锁来实现对同一变量的安全访问。

ThreadLocal从另一角度来解决多线程的并发，它是将需要并发访问的资源复制成多份，每个线程拥有一份资源，没必要对该变量进行同步了。

ThreadLocal并不能代替同步机制，两者的问题领域不同，同步机制是为了同步多个线程对相同的资源进行并发访问，是多线程之间进行通信的有效方式。ThreadLocal是为了隔离多个线程的数据共享，从根本上避免多个线程之间对共享资源的竞争。

最常见的ThreadLocal使用场景为用来解决数据库连接、Session管理等。

下面小程序说明了ThreadLocal能达到在每个线程中创建变量副本的效果：

package threadtest;

public class ThreadTest implements Runnable{

    private ThreadLocal<Integer> i =new ThreadLocal<>();

    public int getI() {

        return i.get();

    }

    public void setI(int i) {

        this.i.set(i);

    }

    @Override

    public void run() {

        for(i.set(0);i.get()<100;i.set(i.get()+1)) {

            System.out.println(Thread.currentThread().getName() + "--------->" + i.get());

        }

    }

    public static void main(String[] args)  {

        //两个线程，各自打印各自的值

        ThreadTest tt = new ThreadTest();

        Thread t1 = new Thread(tt,"t1");

        Thread t2 = new Thread(tt,"t2");

        t1.start();

        t2.start();

    }

}

结果：i变量两个线程各自不影响

t1--------->0

t2--------->0

t1--------->1

t2--------->1

t1--------->2

t2--------->2

t1--------->3

t2--------->3

...

t2--------->94

t2--------->95

t2--------->96

t2--------->97

t2--------->98

t2--------->99

t1--------->15

t1--------->16

t1--------->17

t1--------->18

...

t1--------->97

t1--------->98

t1--------->99

二、包装线程不安全的集合

Java集合中ArrayList,LinkedList,HashSet,TreeSet,HashMap,TreeMap等都是线程不安全的，就是多个线程并发向这些集合中存取数据，可能会破坏数据的完整性。

如果要多线程访问这些集合，就需要包装下，需要用到Collections提供的静态方法把这些集合包装成安全的集合，方法如下：

static <T> Collection<T> synchronizedCollection(Collection<T> c)

static <T> List<T> synchronizedList(List<T> list)

static <K,V> Map<K,V> synchronizedMap(Map<K,V> m)

static <T> Set<T> synchronizedSet(Set<T> s)

static <K,V> SortedMap<K,V> synchronizedSortedMap(SortedMap<K,V> m)

static <T> SortedSet<T> synchronizedSortedSet(SortedSet<T> s)

//将ArrayList包装成安全的

List<String> l =Collections.synchronizedList(new ArrayList<String>());

三、线程安全的集合类

Java5开始，java.util.concurrent包下提供了大量支持高并发访问的集合接口和实现类

主要分为两类:

以Concurrent开头的集合类，如：ConcurrentHashMap,ConcurrentSkipListMap,ConcurrentSkipListSet,ConcurrentLinkedQueue,ConcurrentLinkedDeque

以CopyOnWrite开头的集合类，如: CopyOnWriteArrayList,CopyOnWriteArraySet.

其中Concurrent开头的集合类代表了并发访问的集合，支持多线程并发写入访问，这些写入程序的所有操作都是线程安全的，但读取不会锁定。

当多个线程共享访问一个公共集合时，ConcurrentLinkedQueue是一个不错的选择。ConcurrentLinkedQueue实现了多线程的高效访问，个线程访问时无需等待

在默认情况下ConcurrentHashMap支持16个线程并发写入，超过16个时，可能有些线程需要等待。

巴特西

java并发编程基础——线程相关的类

最新文章

热门文章