在多线程中如何保证集合的安全

Posted 2020-11-21 huangdabing

线程和进程

进程(Process)的概念。狭义的进程是正在运行的程序的实例；广义的进程是一个具有一定独立功能的程序关于某个数据集合的一次运行活动，是操作系统动态执行的基本单元。

线程(Thread)，有时被称为轻量级进程(LWP)，是程序执行流的最小单位；一个标准的线程由线程ID、当前指令指针(PC)、寄存器集合和堆栈组成。

通常情况下，一个进程由一个到多个线程组成，各个线程之间共享程序的内存空间及一些进程级的资源。

在大多数软件应用中，线程的数量都不止一个，多线程程序处在一个多变的环境中，可访问的全局变量和堆数据随时都可能被其他的线程改变，这就将“线程安全”的问题提上了议程。那么，如何确保线程的安全？

 

确保线程安全的方法

一般说来，基于Linux操作系统，确保线程安全的方法有这几个：竞争与原子操作、同步与锁、可重入、过度优化。

 

竞争与原子操作
多个线程同时访问和修改一个数据，可能造成很严重的后果。出现严重后果的原因是很多操作被操作系统编译为汇编代码之后不止一条指令，因此在执行的时候可能执行了一半就被调度系统打断了而去执行别的代码了。一般将单指令的操作称为原子的(Atomic)，因为不管怎样，单条指令的执行是不会被打断的。

 

因此，为了避免出现多线程操作数据的出现异常，Linux系统提供了一些常用操作的原子指令，确保了线程的安全。但是，它们只适用于比较简单的场合，在复杂的情况下就要选用其他的方法了。

 

同步与锁
为了避免多个线程同时读写一个数据而产生不可预料的后果，开发人员要将各个线程对同一个数据的访问同步，也就是说，在一个线程访问数据未结束的时候，其他线程不得对同一个数据进行访问。

 

同步的最常用的方法是使用锁(Lock)，它是一种非强制机制，每个线程在访问数据或资源之前首先试图获取锁，并在访问结束之后释放锁；在锁已经被占用的时候试图获取锁时，线程会等待，直到锁重新可用。

 

二元信号量是最简单的一种锁，它只有两种状态：占用与非占用，它适合只能被唯一一个线程独占访问的资源。对于允许多个线程并发访问的资源，要使用多元信号量(简称信号量)。

 

可重入
一个函数被重入，表示这个函数没有执行完成，但由于外部因素或内部因素，又一次进入该函数执行。一个函数称为可重入的，表明该函数被重入之后不会产生任何不良后果。可重入是并发安全的强力保障，一个可重入的函数可以在多线程环境下放心使用。

 

过度优化
在很多情况下，即使我们合理地使用了锁，也不一定能够保证线程安全，因此，我们可能对代码进行过度的优化以确保线程安全。

 

我们可以使用volatile关键字试图阻止过度优化，它可以做两件事：第一，阻止编译器为了提高速度将一个变量缓存到寄存器而不写回；第二，阻止编译器调整操作volatile变量的指令顺序。

 

在另一种情况下，CPU的乱序执行让多线程安全保障的努力变得很困难，通常的解决办法是调用CPU提供的一条常被称作barrier的指令，它会阻止CPU将该指令之前的指令交换到barrier之后，反之亦然。

 

在循环中修改集合数据的问题

看代码：

List asList = Arrays.asList(1,2);
  for(int i:asList){
  asList.add(3);
  System.err.println(i);
}

我们执行这段代码会抛出这个异常 java.lang.UnsupportedOperationException，这个异常告诉我们，不支持在迭代中修改当前的集合（增加或删除元素）；

为什么会这样？那我们应该如果避免这个问题呢？

1、foreach循环中是不支持对集合中的元素删除或添加的。

2、使用Arrays.asList产生的集合不支持在循环中更改；使用new ArrayList是可以的；但是我们不应该使用这种写法；因为元素的添加会移除会导致集合的长度发生变化；这极容易导致BUG；并且不易排查。

3、如果确实需要在循环中移除元素； 可以考虑使用迭代器进行操作Iterator。

但是如果我们在一个多线程的程序中使用了一个共享的集合；我们怎么能保证其它线和不更改集合中的元素？

　　可以使用Collections.synchronizedList获取一个线程安全的集合，要想在循环集合的时候保证线程的安全必须在循环的外层为所需要循环或迭代的集合添加锁控制；即获取当前集合持有的锁进行访问控制；

代码：

final static List asList = Collections.synchronizedList(new ArrayList(Arrays.asList("a","b")));
public static void main(String[] args) {
    new Thread(new Runnable() {
        @Override
        public void run() {
            try {
　　　　　　　　　　Thread.sleep(150); 
　　　　　　　　　 } 
　　　　　　　catch (
　　　　　　　　　　InterruptedException e) { }
            reload();
        }
        }).start();
    synchronized (asList) {
      for(String e:asList){
            try {Thread.sleep(100);} 　　　　
　　　　　　  catch (InterruptedException e1) {}
        　　 System.out.println(e);
      }
    }
}
public static void reload(){
  asList.clear();
  asList.addAll(Arrays.asList("a","b","c"));
}

注意：如果不使用Collections.synchronizedList获取一个线程安全的集合；就必须在修改集合之前首先获取集合的锁进行同步控制；或者可以使用java.util.concurrent包下的相关线程安全的集合类。