Java并发学习(一)-线程内存模型(转)
标签（空格分隔）： java
原文作者:rainyear
原文链接:http://blog.csdn.net/rainyear/article/details/8855498
看到该篇文章后觉得很受益所以直接转载,其中有些地方加入了自己的理解,希望能帮助更多的人.
1.内存图
Java线程内存模型
所有线程共享主内存,也就是数据来源于主内存
每个线程有自己的工作内存,也就是线程副本变量
refreshing local memory to/from main memory must comply to JMM rules
2.产生线程不安全的原因
线程的working memory是cpu的寄存器和高速缓存的抽象描述：现在的计算机，cpu在计算的时候，并不总是从内存读取数据，它的数据读取顺序优先级 是：寄存器－高速缓存－内存。线程耗费的是CPU，线程计算的时候，原始的数据来自内存，在计算过程中，有些数据可能被频繁读取，这些数据被存储在寄存器和高速缓存中，当线程计算完后，这些缓存的数据在适当的时候应该写回内存。当多个线程同时读写某个内存数据时，就会产生多线程并发问题，涉及到三个特 性：原子性，有序性，可见性。 支持多线程的平台都会面临 这种问题，运行在多线程平台上支持多线程的语言应该提供解决该问题的方案。
JVM是一个虚拟的计算机，它也会面临多线程并发问题，Java程序运行在java虚拟机平台上，java程序员不可能直接去控制底层线程对寄存器高速缓存内存之间的同步，那么java从语法层面，应该给开发人员提供一种解决方案，这个方案就是诸如 synchronized, volatile,锁机制（如同步块，就绪队 列，阻塞队列）等等。这些方案只是语法层面的，但我们要从本质上去理解它；
每个线程都有自己的执行空间(即工作内存)，线程执行的时候用到某变量，首先要将变量从主内存拷贝的自己的工作内存空间，然后对变量进行操作：读取，修改，赋值等，这些均在工作内存完成，操作完成后再将变量写回主内存；
各个线程都从主内存中获取数据，线程之间数据是不可见的；打个比方：主内存变量A原始值为1，线程1从主内存取出变量A，修改A的值为2，在线程1未将变量A写回主内存的时候，线程2拿到变量A的值仍然为1；
这便引出“可见性”的概念：当一个共享变量在多个线程的工作内存中都有副本时，如果一个线程修改了这个共享变量的副本值，那么其他线程应该能够看到这个被修改后的值，这就是多线程的可见性问题。
普通变量情况：如线程A修改了一个普通变量的值，然后向主内存进行写回，另外一条线程B在线程A回写完成了之后再从主内存进行读取操作，新变量的值才会对线程B可见；
3.如何保证线程安全?
编写线程安全的代码，本质上就是管理对状态（state）的访问，而且通常都是共享的、可变的状态。这里的状态就是对象的变量(静态变量和实例变量)线程安全的前提是该变量是否被多个线程访问, 保证对象的线程安全性需要使用同步来协调对其可变状态的访问；若是做不到这一点，就会导致脏数据和其他不可预期的后果。无论何时，只要有多于一个的线程访问给定的状态变量，而且其中某个线程会写入该变量，此时必须使用同步来协调线程对该变量的访问。Java中首要的同步机制是synchronized关键字，它提供了独占锁。除此之外，术语“同步”还包括volatile变量，显示锁和原子变量的使用。
在没有正确同步的情况下，如果多个线程访问了同一个变量，你的程序就存在隐患。有3种方法修复它：
- 不要跨线程共享变量；
- 使状态变量为不可变的;
- 在任何访问状态变量的时候使用同步。
volatile要求程序对变量的每次修改，都写回主内存，这样便对其它线程可见，解决了可见性的问题，但是不能保证数据的一致性；特别注意：原子操作：根据Java规范，对于基本类型的赋值或者返回值操作，是原子操作。但这里的基本数据类型不包括long和double, 因为JVM看到的基本存储单位是32位，而long和double都要用64位来表示。所以无法在一个时钟周期内完成
通俗的讲一个对象的状态就是它的数据，存储在状态变量中，比如实例域或者静态域；无论何时，只要多于一个的线程访问给定的状态变量。而且其中某个线程会写入该变量，此时必须使用同步来协调线程对该变量的访问；
同步锁：每个JAVA对象都有且只有一个同步锁，在任何时刻，最多只允许一个线程拥有这把锁。当一个线程试图访问带有synchronized(this)标记的代码块时，必须获得 this关键字引用的对象的锁，在以下的两种情况下，本线程有着不同的命运。
1、 假如这个锁已经被其它的线程占用，JVM就会把这个线程放到本对象的锁池中。本线程进入阻塞状态。锁池中可能有很多的线程，等到其他的线程释放了锁，JVM就会从锁池中随机取出一个线程，使这个线程拥有锁，并且转到就绪状态。
2、 假如这个锁没有被其他线程占用，本线程会获得这把锁，开始执行同步代码块。
（一般情况下在执行同步代码块时不会释放同步锁，但也有特殊情况会释放对象锁
如在执行同步代码块时，遇到异常而导致线程终止，锁会被释放；在执行代码块时，执行了锁所属对象的wait()方法，这个线程会释放对象锁，进入对象的等待池中）
Synchronized关键字保证了数据读写一致和可见性等问题，但是他是一种阻塞的线程控制方法，在关键字使用期间，所有其他线程不能使用此变量，这就引出了一种叫做非阻塞同步的控制线程安全的需求；
ThreadLocal顾名思义它是local variable（线程局部变量）。它的功用非常简单，就是为每一个使用该变量的线程都提供一个变量值的副本，是每一个线程都可以独立地改变自己的副本，而不会和其它线程的副本冲突。从线程的角度看，就好像每一个线程都完全拥有该变量。
每个线程都保持对其线程局部变量副本的隐式引用，只要线程是活动的并且 ThreadLocal 实例是可访问的；在线程消失之后，其线程局部实例的所有副本都会被垃圾回收（除非存在对这些副本的其他引用）
Object wait()和notify()方法解析
Object的wait（）和notify（）、notifyAll（）方法，使用一个对象作为锁，然后调用wait()就会挂起当前线程，同时释放对象锁；
notify()使用要首先获取对象锁，然后才能唤醒被挂起的线程（因为等待对象锁而挂起的）
notifyAll（）：唤醒在此对象监视器上等待的所有线程。
wait（）在其他线程调用此对象的 notify() 方法或 notifyAll() 方法前，导致当前线程等待。
抛出：IllegalMonitorStateException - 如果当前线程不是此对象监视器的所有者
package com.taobao.concurrency;
public class WaitTest {
public static String a = "";// 作为监视器对象
public static void main(String[] args) throws InterruptedException {
WaitTest wa = new WaitTest();
TestTask task = wa.new TestTask();
Thread t = new Thread(task);
t.start();
Thread.sleep(12000);
for (int i = 5; i > 0; i--) {
System.out.println("快唤醒挂起的线程************");
Thread.sleep(1000);
}
System.out.println("收到，马上！唤醒挂起的线程************");
synchronized (a) {
a.notifyAll();
}
}
class TestTask implements Runnable {
@Override
public void run() {
synchronized (a) {
try {
for (int i = 10; i > 0; i--) {
Thread.sleep(1000);
System.out.println("我在运行 ***************");
}
a.wait();
for (int i = 10; i > 0; i--) {
System.out.println("谢谢唤醒**********又开始运行了*******");
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
用ArrayBlockingQueue解决生产者消费者问题；默认使用的是非公平锁
take():取走BlockingQueue里排在首位的对象,若BlockingQueue为空,阻断进入等待状态直到Blocking有新的对象被加入为止，若请求不到此线程被加入阻塞队列；
如果使用公平锁，当有内容可以消费时，会从队首取出消费者线程进行消费(即等待时间最长的线程)
add(anObject):把anObject加到BlockingQueue里,即如果BlockingQueue可以容纳,则返回true,否则招聘异常
package com.taobao.concurrency;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class TestBlockingQueues {
public static void main(String[] args) {
BlockingQueue<String> queue = new ArrayBlockingQueue<String>(20);
Thread pro = new Thread(new Producer(queue), "生产者");
pro.start();
for (int i = 0; i < 10; i++) {
Thread t = new Thread(new Concumer(queue), "消费者 " + i);
t.start();
}
}
}
class Producer implements Runnable {
BlockingQueue<String> queue;
public Producer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
int i = 0;
while (true) {
try {
System.out.println("生产者生产食物， 食物编号为：" + i);
queue.put(" 食物 " + i++);
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println("生产者被中断");
}
}
}
}
class Concumer implements Runnable {
BlockingQueue<String> queue;
public Concumer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
while (true) {
try {
System.out.println(Thread.currentThread().getName() + "消费："
+ queue.take());
} catch (InterruptedException e) {
System.out.println("消费者被中断");
}
}
}
}
执行结果：
消费者 0 请求消费
消费者 2 请求消费
消费者 4 请求消费
消费者 6 请求消费
消费者 8 请求消费
消费者 5 请求消费
生产者生产食物， 食物编号为：0
消费者 0消费： 食物 0
消费者 1 请求消费
消费者 3 请求消费
消费者 7 请求消费
消费者 9 请求消费
消费者 0 请求消费
生产者生产食物， 食物编号为：1
消费者 2消费： 食物 1
消费者 2 请求消费
生产者生产食物， 食物编号为：2
消费者 4消费： 食物 2
消费者 4 请求消费
生产者生产食物， 食物编号为：3
消费者 6消费： 食物 3
消费者 6 请求消费
生产者生产食物， 食物编号为：4
消费者 8消费： 食物 4
消费者 8 请求消费
生产者生产食物， 食物编号为：5
