聊聊并发（一）——初始JUC

一、volatile

1、介绍

　　JDK 5.0 提供了java.util.concurrent包，在此包中增加了并发编程中很常用的使用工具类，用于定义类似于线程的自定义子系统，包括线程池、异步IO和轻量级任务框架。提供可调的、灵活的线程池。还提供了设计用于多线程上下文的Collection实现等。

2、内存可见性

　　内存可见性是指当某个线程正在使用对象状态而另一线程在同时修改该状态，需要确保当一个线程修改了对象状态后，其他线程能够看到发生的状态变化。
　　可见性错误是指当读操作与写操作在不同的线程中执行时，我们无法确保执行读操作的线程能实时的看到其他线程写入之后的值，有时甚至是根本不可能的事情。
　　我们可以通过同步来保证对象被安全的发布。除此之外我们也可以使用一种更加轻量级的volatile变量。
　　内存可见性问题：当多个线程同时操作共享数据时，对共享数据的操作彼此是不可见的。
　　代码示例：内存可见性问题

public class VolatileDemo implements Runnable {

    private boolean flag = false;

    @Override
    public void run() {

        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
        }

        flag = true;
        System.out.println("flag = " + isFlag());
    }

    public boolean isFlag() {
        return flag;
    }

    public void setFlag(boolean flag) {
        this.flag = flag;
    }

}

// 测试类
public class Main {
    public static void main(String[] args) {
        VolatileDemo demo = new VolatileDemo();
        new Thread(demo).start();

        while (true) {
            if (demo.isFlag()) {
                System.out.println("this is main");
                break;
            }
        }
    }
}

// 结果1
flag = true
this is main
// 程序结束

// 结果2
flag = true
// 程序死循环

　　问题：结果1不难理解，当线程执行完毕后，主线程才开始执行while。为什么结果2是死循环呢？
　　原因：JVM为每一个执行任务的线程，它都会分配一个独立的工作内存用于提高效率。每次都会从主存中读取变量的副本到各自的工作内存中，修改后，再写回主存中。
　　那么，不难理解结果2：主线程从主存读取flag = false，因为用的while循环，while属于底层的东西，执行速度非常快，没有再读主存的机会，一直读取的是自己的工作内存（flag = false）。而当线程1读到flag并修改为true，回写到主存时，主线程并不知道，所以死循环。

　　解决：知道问题原因了，如何解决呢？
　　代码示例：方式一、加锁

// 方式一
public class Main {
    public static void main(String[] args) {
        VolatileDemo demo = new VolatileDemo();
        new Thread(demo).start();

        while (true) {
            synchronized (demo) {
                if (demo.isFlag()) {
                    System.out.println("this is main");
                    break;
                }
            }
        }
    }
}

　　分析：synchronize加锁可以解决。加了锁，就可以让while循环每次都从主存中去读取数据，这样就能读取到true了。但是加锁效率极低。每次只能有一个线程访问，当一个线程持有锁时，其他线程就会阻塞，效率就非常低了。不想加锁，又要解决内存可见性问题，那么就可以使用volatile关键字。
　　代码示例：方式二、用volatile修饰

private volatile boolean flag = false;

3、volatile关键字

　　Java提供了一种稍弱的同步机制——volatile关键字，当多个线程访问共享数据时，可以保证内存可见性，即内存中的数据可见。用这个关键字修饰共享数据，就会及时的把线程工作内存中的数据刷新到主存中去，也可以理解为，就是直接操作主存中的数据。
　　可以将volatile看做一个轻量级的锁，相较于synchronized是一种轻量级的同步策略。与锁（synchronize）的区别：
　　volatile不具备互斥性。即一个线程访问共享数据，另一个线程依然可以访问。所有的访问都在主存中完成，保证内存可见性。
　　synchronized具备互斥性。即一个线程抢到锁，另一个线程进不来，必须等待。
　　volatile不能保证变量的原子性。

二、i++问题

1、原子性

　　所谓原子性就是一组操作不可再细分。要么全都做，要么全都不做。前面提到volatile不能保证变量的原子性，具体表现如下：
　　代码示例：原子性问题

public class AtomicDemo implements Runnable {

    // 此时是加了volatile语义的
    private volatile int i = 0;

    @Override
    public void run() {

        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
        }

        System.out.println(getI());
    }

    public int getI() {
        return i++;
    }

}

// 测试类
public class Main {
    public static void main(String[] args) {
        AtomicDemo atomicDemo = new AtomicDemo();

        // 开启 10 个线程对共享数据进行自增后打印。
        for (int i = 0; i < 10; i++) {
            new Thread(atomicDemo).start();
        }
    }
}

// 可能的一种结果
0
5
4
3
2
1
0
6
6
7

　　问题：期望结果应该每个线程对 i 自增一次，最终 i 的值为10。实际结果如上（有重复数据）。
　　原因：i++操作不是一个原子性操作，实际分为读改写三步，如下：

　　int temp = i; // 从主存中读
　　i = i + 1; // cpu 对 i 进行+1运算
　　i = temp; // 写回主存

　　而volatile不能保证变量的原子性。volatile，只是相当于所有线程都是在主存中操作数据而已，并不具备互斥性。比如两个线程同时读取主存中的0，然后又同时自增，同时写入主存，结果还是会出现重复数据。volatile的不具备互斥性也导致了它不具备原子性。
　　解决：知道问题原因了，如何解决呢？
　　代码示例：方式一、加锁

public synchronized int getI() {
    return i++;
}

　　代码示例：方式二、原子变量

private AtomicInteger i = new AtomicInteger();
public int getI() {
    return i.getAndIncrement();
}

2、原子变量

　　JDK 1.5 以后java.util.concurrent.atomic包下提供了常用的原子变量。这些原子变量具备以下特点：volatile的内存可见性；CAS算法保证数据的原子性。
　　类的小工具包，支持在单个变量上解除锁的线程安全编程。事实上，此包中的类可将volatile值、字段和数组元素的概念扩展到那些也提供原子条件更新操作的类。
　　类AtomicBoolean、AtomicInteger、AtomicLong和AtomicReference的实例各自提供对相应类型单个变量的访问和更新。每个类也为该类型提供适当的实用工具方法。
　　AtomicIntegerArray、AtomicLongArray和AtomicReferenceArray类进一步扩展了原子操作，对这些类型的数组提供了支持。这些类在为其数组元素提供volatile访问语义方面也引人注目，这对于普通数组来说是不受支持的。
　　核心方法：boolean compareAndSet(int expectedValue, int updateValue)
　　java.util.concurrent.atomic包下提供了一些原子操作的常用类：

　　AtomicBoolean、AtomicInteger、AtomicLong、AtomicReference<V>
　　AtomicIntegerArray、AtomicLongArray
　　AtomicMarkableReference<V>
　　AtomicReferenceArray<E>
　　AtomicStampedReference<V>

3、CAS算法

　　CAS（Compare and Swap）是一种硬件对并发的支持，针对多处理器操作而设计的处理器中的一种特殊指令，用于管理对共享数据的并发访问，是硬件对于并发操作共享数据的支持。
　　CAS是一种无锁的非阻塞算法的实现。不存在上下文切换的问题。
　　CAS包含了3个操作数：内存值V，比较值A，更新值B。当且仅当V == A时，V = B，否则不执行任何操作。
　　CAS算法：当多个线程并发的对主存中的数据进行修改的时候。有且只有一个线程会成功，其他的都会失败。（同时操作，只是会失败而已，并不会被锁之类的）。
　　CAS比普通同步锁效率高，原因：CAS算法当这一次不成功的时候，它下一次不会阻塞，也就是它不会放弃CPU的执行权，它可以立即再次尝试，再去更新。
　　代码示例：模拟CAS算法

// 模拟CAS算法
public class CompareAndSwap {
    private int value;

    // 获取内存值
    public synchronized int get() {
        return value;
    }

    // 比较
    public synchronized int compareAndSwap(int expectedValue, int newValue) {
        int oldValue = value;

        if (oldValue == expectedValue) {
            this.value = newValue;
        }

        return oldValue;
    }

    // 设置
    public synchronized boolean compareAndSet(int expectedValue, int newValue) {
        return expectedValue == compareAndSwap(expectedValue, newValue);
    }
}

// 测试类
public class Main {
    public static void main(String[] args) {
        final CompareAndSwap cas = new CompareAndSwap();

        for (int i = 0; i < 10; i++) {
            new Thread(() -> {

                int expectedValue = cas.get();
                boolean b = cas.compareAndSet(expectedValue, (int) (Math.random() * 101));

                System.out.println(b);

            }).start();
        }
 
    }
}

三、锁分段机制

1、concurrentHashMap

　　JDK 1.5之后，在java.util.concurrent包中提供了多种并发容器类来改进同步容器类的性能。其中最主要的就是ConcurrentHashMap，采用"锁分段"机制。
　　HashMap是线程不安全的；Hashtable 加了锁，是线程安全的，因此它效率低。Hashtable 加锁就是将整个hash表锁起来，当有多个线程访问时，同一时间只能有一个线程访问，并行变成串行，因此效率低。
　　ConcurrentHashMap是一个线程安全的hash表。对于多线程的操作，介于 HashMap 与 Hashtable 之间。内部采用"锁分段"机制替代 Hashtable 的独占锁，进而提高性能。

　　每个段都是一个独立的锁。JDK 1.8 以后concurrentHashMap的锁分段被取消了。采用的是CAS算法。
　　此包还提供了设计用于多线程上下文中的 Collection 实现：

　　ConcurrentHashMap
　　ConcurrentSkipListMap
　　ConcurrentSkipListSet
　　CopyOnWriteArrayList
　　CopyOnWriteArraySet

　　当期望多线程访问一个给定 collection 时，ConcurrentHashMap 通常优于同步的 HashMap，ConcurrentSkipListMap 通常优于同步的 TreeMap。当期望的读数和遍历远远大于列表的更新数时，CopyOnWriteArrayList 优于同步的 ArrayList。

2、CopyOnWriteArrayList

　　代码示例：CopyOnWriteArrayList

// 不写注释也能看懂的代码
public class CopyOnWriteArrayListDemo implements Runnable {

    private static final List<String> list = Collections.synchronizedList(new ArrayList<>());
    //private static final CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<>();

    static {
        list.add("AA");
        list.add("BB");
        list.add("CC");
    }

    @Override
    public void run() {
        Iterator<String> it = list.iterator();
        while (it.hasNext()) {
            System.out.println(it.next());

            list.add("AA");
        }
    }
}

// 测试类
public class Main {
    public static void main(String[] args) {
        CopyOnWriteArrayListDemo ht = new CopyOnWriteArrayListDemo();

        new Thread(ht).start();
    }
}

// 结果(有并发修改异常)
AA
Exception in thread "Thread-0" java.util.ConcurrentModificationException

　　如果用CopyOnWriteArrayList，则不会有异常。
　　CopyOnWriteArrayList：写入并复制，添加操作多时，效率低，因为每次添加时都会进行复制，开销非常的大。并发迭代操作多时可以选择。

四、CountDownLatch（闭锁）

1、介绍

　　java.util.concurrent包中提供了多种并发容器类来改进同步容器的性能。CountDownLatch是一个同步辅助类，在完成某些运算时，只有其他所有线程的运算全部完成，当前运算才继续执行，这就叫闭锁。

2、案例

　　代码示例：计算10个线程打印偶数的时间

// 不写注释也能看懂的代码
public class CountDownLatchDemo implements Runnable {

    private final CountDownLatch latch;

    public CountDownLatchDemo(CountDownLatch latch) {
        this.latch = latch;
    }

    @Override
    public void run() {
        try {
            for (int i = 0; i < 50000; i++) {
                if (i % 2 == 0) {
                    System.out.println(i);
                }
            }
        } finally {
            // 完成一个线程，计数 -1
            latch.countDown();
        }
    }

}

// 测试类
public class Main {

    public static void main(String[] args) {
        final CountDownLatch latch = new CountDownLatch(10);
        CountDownLatchDemo ld = new CountDownLatchDemo(latch);

        long start = System.currentTimeMillis();

        for (int i = 0; i < 10; i++) {
            new Thread(ld).start();
        }

        try {
            // 等待10个线程都执行完
            latch.await();
        } catch (InterruptedException e) {
        }

        long end = System.currentTimeMillis();

        System.out.println("耗费时间为：" + (end - start));
    }

}

五、Callable

　　Callable和Runable的区别是，Callable带泛型，其call方法有返回值。使用的时候，需要用FutureTask来接收返回值。而且它也要等到线程执行完调用get方法才会执行，也可以用于闭锁操作。
　　代码示例：

// 不写注释也能看懂的代码
public class CallableDemo implements Callable<Integer> {

    @Override
    public Integer call() throws Exception {
        int sum = 0;

        for (int i = 0; i <= 100; i++) {
            sum += i;
        }

        return sum;
    }
}

// 测试类
public class Main {
    public static void main(String[] args) {
        CallableDemo demo = new CallableDemo();

        //执行 Callable 方式，需要 FutureTask 实现类的支持，用于接收运算结果。
        FutureTask<Integer> result = new FutureTask<>(demo);
        new Thread(result).start();

        try {
            // get()方法是阻塞的
            Integer sum = result.get();
            System.out.println(sum);

            System.out.println("--------表明 get()方法是阻塞的-------------");
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }
}

六、Lock同步锁

　　在JDK1.5之前，解决多线程安全问题用sychronized隐式锁：同步代码块；同步方法。
　　在JDK1.5之后，出现了更加灵活的方式Lock显式锁：同步锁。
　　Lock需要通过lock()方法上锁，通过unlock()方法释放锁。为了保证锁能释放，所有unlock方法一般放在finally中去执行。
　　代码示例：卖票问题

// 不写注释也能看懂的代码
public class LockDemo implements Runnable {

    private int tick = 100;

    private final Lock lock = new ReentrantLock();

    @Override
    public void run() {
        while (true) {
            //上锁
            lock.lock();

            try {
                if (tick > 0) {

                    try {
                        Thread.sleep(200);
                    } catch (InterruptedException e) {
                    }

                    System.out.println(Thread.currentThread().getName() + " 完成售票，余票为：" + --tick);
                } else {
                    break;
                }
            } finally {
                //释放锁
                lock.unlock();
            }
        }
    }
}

// 测试类
public class Main {
    public static void main(String[] args) {
        LockDemo ticket = new LockDemo();

        // 开了3个窗口卖票
        new Thread(ticket, "1号窗口").start();
        new Thread(ticket, "2号窗口").start();
        new Thread(ticket, "3号窗口").start();
    }
}

// 可能的结果.这里只出最后10张票的结果值
2号窗口 完成售票，余票为：9
2号窗口 完成售票，余票为：8
3号窗口 完成售票，余票为：7
3号窗口 完成售票，余票为：6
3号窗口 完成售票，余票为：5
3号窗口 完成售票，余票为：4
3号窗口 完成售票，余票为：3
3号窗口 完成售票，余票为：2
1号窗口 完成售票，余票为：1
2号窗口 完成售票，余票为：0

七、ReadWriterLock读写锁

　　多个线程并发读数据，是不会出现问题。但是，多个线程并发写数据，到底是写入哪个线程的数据呢？所以，写写/读写需要互斥，读读不需要互斥。这个时候可以用读写锁来提高效率。
　　ReadWriteLock 维护了一对相关的锁，一个用于只读操作，另一个用于写入操作。只要没有 writer，读取锁可以由多个 reader 线程同时保持。
　　读锁，可以多个线程并发的持有。
　　写锁，是独占的。
　　源码示例：读写锁

public interface ReadWriteLock {
    // 返回一个读锁
    Lock readLock();

    // 返回一个写锁
    Lock writeLock();
}

　　代码示例：

public class ReadWriteLockDemo {

    private int number = 0;

    private final ReadWriteLock lock = new ReentrantReadWriteLock();

    // 读.可以多个线程并发读
    public void read() {
        // 上读锁
        lock.readLock().lock();

        try {
            System.out.println(Thread.currentThread().getName() + " : " + number);
        } finally {
            // 释放读锁
            lock.readLock().unlock();
        }
    }

    // 写.一次只能有一个线程操作
    public void write(int number) {
        // 上写锁
        lock.writeLock().lock();

        try {
            System.out.println(Thread.currentThread().getName());
            this.number = number;
        } finally {
            // 释放写锁
            lock.writeLock().unlock();
        }
    }
}

// 测试类
public class Main {
    public static void main(String[] args) {
        ReadWriteLockDemo rw = new ReadWriteLockDemo();

        // 开启 1 个线程写
        new Thread(new Runnable() {
            @Override
            public void run() {
                rw.write((int) (Math.random() * 101));
            }
        }, "Write:").start();

        // 开启 100 个线程读
        for (int i = 0; i < 100; i++) {
            new Thread(new Runnable() {

                @Override
                public void run() {
                    rw.read();
                }
            }).start();
        }
    }
}