并发编程系列教程（02） - 多线程安全

文章涉及到的代码已上传到Github，有兴趣的同学可以参考下（https://github.com/ylw-github/Java-ThreadDemo）

1. 什么是线程安全

当多个线程同时共享时，全局变量或静态变量,做写操作时，可能会发生数据冲突的过程，也就是线程安全的问题。但是做读操作是不会发生数据冲突问题。

案例:需求现在有100张火车票，有两个窗口同时抢火车票，请使用多线程模拟抢票效果。

package com.ylw.thread;

public class ThreadSafeDemo {
    
    public static class ThreadTrain implements Runnable {
        private int trainCount = 100;

        @Override
        public void run() {
            while (trainCount > 0) {
                try {
                    Thread.sleep(50);
                } catch (Exception e) {

                }
                sale();
            }
        }

        public void sale() {
            if (trainCount > 0) {
                System.out.println(Thread.currentThread().getName() + ",出售第" + (100 - trainCount + 1) + "张票");
                trainCount--;
            }
        }

        public static void main(String[] args) {
            ThreadTrain threadTrain = new ThreadTrain();
            Thread t1 = new Thread(threadTrain, "①号");
            Thread t2 = new Thread(threadTrain, "②号");
            t1.start();
            t2.start();
        }

    }
}

运行结果: 一号窗口和二号窗口同时出售火车第九十五张,部分火车票会重复出售。

结论发现，多个线程共享同一个全局成员变量时，做写的操作可能会发生数据冲突问题。

2. 线程安全的解决方法

问:如何解决多线程之间线程安全问题

答:使用多线程之间同步synchronized或使用锁(lock)。

问:为什么使用线程同步或使用锁能解决线程安全问题呢？ 答:将可能会发生数据冲突问题(线程不安全问题)，只能让当前一个线程进行执行。代码执行完成后释放锁，让后才能让其他线程进行执行。这样的话就可以解决线程不安全问题。

问:什么是多线程之间同步 答:当多个线程共享同一个资源,不会受到其他线程的干扰。

问:什么是多线程同步 答:当多个线程共享同一个资源,不会受到其他线程的干扰。

2.1 内置的锁

Java提供了一种内置的锁机制来支持原子性

每一个Java对象都可以用作一个实现同步的锁，称为内置锁，线程进入同步代码块之前自动获取到锁，代码块执行完成正常退出或代码块中抛出异常退出时会释放掉锁。

内置锁为互斥锁，即线程A获取到锁后，线程B阻塞直到线程A释放锁，线程B才能获取到同一个锁。

内置锁使用synchronized关键字实现，synchronized关键字有两种用法：

1. 修饰需要进行同步的方法（所有访问状态变量的方法都必须进行同步），此时充当锁的对象为调用同步方法的对象
2. 同步代码块和直接使用synchronized修饰需要同步的方法是一样的，但是锁的粒度可以更细，并且充当锁的对象不一定是this，也可以是其它对象，所以使用起来更加灵活

2.2 同步代码块synchronized

就是将可能会发生线程安全问题的代码，给包括起来。
synchronized(同一个数据){
 可能会发生线程冲突问题
}
就是同步代码块 
synchronized(对象)//这个对象可以为任意对象 
{ 
    需要被同步的代码 
} 

对象如同锁，持有锁的线程可以在同步中执行

没持有锁的线程即使获取CPU的执行权，也进不去

同步的前提：

1. 必须要有两个或者两个以上的线程
2. 必须是多个线程使用同一个锁

必须保证同步中只能有一个线程在运行

• 好处： 解决了多线程的安全问题

• 弊端： 多个线程需要判断锁，较为消耗资源、抢锁的资源。

代码样例:

public void sale() {
		synchronized (this) {
			if (trainCount > 0) {
				System.out.println(Thread.currentThread().getName() + ",出售第" + (100 - trainCount + 1) + "张票");
				trainCount--;
			}
		}
	}

2.3 同步方法

什么是同步方法？

答：在方法上修饰synchronized 称为同步方法

代码样例:

public synchronized void sale() {
		if (trainCount > 0) {
			System.out.println(Thread.currentThread().getName() + ",出售第" + (100 - trainCount + 1) + "张票");
			trainCount--;
		}
	}

同步方法使用的是什么锁？

答：同步函数使用this锁。

证明方式: 一个线程使用同步代码块(this明锁),另一个线程使用同步函数。如果两个线程抢票不能实现同步，那么会出现数据错误。

代码:

package com.ylw.thread;

public class LockDemo {
    static class Thread009 implements Runnable {
        private int trainCount = 100;
        private Object oj = new Object();
        public boolean flag = true;

        public void run() {

            if (flag) {
                while (trainCount > 0) {
                    synchronized (this) {
                        try {
                            Thread.sleep(10);
                        } catch (Exception e) {
                            // TODO: handle exception
                        }
                        if (trainCount > 0) {
                            System.out
                                    .println(Thread.currentThread().getName() + "," + "出售第" + (100 - trainCount + 1) + "票");
                            trainCount--;
                        }
                    }

                }
            } else {
                while (trainCount > 0) {
                    sale();
                }

            }

        }

        public synchronized void sale() {

            try {
                Thread.sleep(10);
            } catch (Exception e) {
                // TODO: handle exception
            }
            if (trainCount > 0) {
                System.out.println(Thread.currentThread().getName() + "," + "出售第" + (100 - trainCount + 1) + "票");
                trainCount--;
            }

        }
    }

    public static void main(String[] args) throws InterruptedException {
        Thread009 threadTrain = new Thread009();
        Thread t1 = new Thread(threadTrain, "窗口1");
        Thread t2 = new Thread(threadTrain, "窗口2");
        t1.start();
        Thread.sleep(40);
        threadTrain.flag = false;
        t2.start();

    }
}

2.4 静态同步函数

问：什么是静态同步函数？

答：方法上加上static关键字，使用synchronized 关键字修饰 或者使用类.class文件。 静态的同步函数使用的锁是 该函数所属字节码文件对象 可以用 getClass方法获取，也可以用当前 类名.class 表示。

代码样例:

public static void sale() {
		synchronized (ThreadTrain3.class) {
			if (trainCount > 0) {
				System.out.println(Thread.currentThread().getName() + ",出售第" + (100 - trainCount + 1) + "张票");
				trainCount--;
			}
		}
}

总结： synchronized 修饰方法使用锁是当前this锁。 synchronized 修饰静态方法使用锁是当前类的字节码文件

3.多线程死锁

问：什么是多线程死锁？ 答:同步中嵌套同步,导致锁无法释放

代码:

class Thread009 implements Runnable {
	private int trainCount = 100;
	private Object oj = new Object();
	public boolean flag = true;

	public void run() {

		if (flag) {
			while (trainCount > 0) {
				synchronized (oj) {
					try {
						Thread.sleep(10);
					} catch (Exception e) {
						// TODO: handle exception
					}
					sale();
				}

			}
		} else {
			while (trainCount > 0) {
				sale();
			}

		}

	}

	public synchronized void sale() {
		synchronized (oj) {
			try {
				Thread.sleep(10);
			} catch (Exception e) {

			}
			if (trainCount > 0) {
				System.out.println(Thread.currentThread().getName() + "," + "出售第" + (100 - trainCount + 1) + "票");
				trainCount--;
			}
		}
	}
}

public class Test009 {
	public static void main(String[] args) throws InterruptedException {
		Thread009 threadTrain = new Thread009();
		Thread t1 = new Thread(threadTrain, "窗口1");
		Thread t2 = new Thread(threadTrain, "窗口2");
		t1.start();
		Thread.sleep(40);
		threadTrain.flag = false;
		t2.start();

	}
}}

4.ThreadLocal

ThreadLocal提高一个线程的局部变量，访问某个线程拥有自己局部变量。

当使用ThreadLocal维护变量时，ThreadLocal为每个使用该变量的线程提供独立的变量副本，所以每一个线程都可以独立地改变自己的副本，而不会影响其它线程所对应的副本。

4.1 ThreadLocal的接口方法：

ThreadLocal类接口很简单，只有4个方法，我们先来了解一下：

• void set(Object value) 设置当前线程的线程局部变量的值。
• public Object get() 该方法返回当前线程所对应的线程局部变量。
• public void remove() 将当前线程局部变量的值删除，目的是为了减少内存的占用，该方法是JDK 5.0新增的方法。需要指出的是，当线程结束后，对应该线程的局部变量将自动被垃圾回收，所以显式调用该方法清除线程的局部变量并不是必须的操作，但它可以加快内存回收的速度。
• protected Object initialValue() 返回该线程局部变量的初始值，该方法是一个protected的方法，显然是为了让子类覆盖而设计的。这个方法是一个延迟调用方法，在线程第1次调用get()或set(Object)时才执行，并且仅执行1次。ThreadLocal中的缺省实现直接返回一个null。

4.2 案例

创建三个线程，每个线程生成自己独立序列号，代码如下:

public class ThreadLocalDemo {

    public static class Res {

        // 生成序列号共享变量
        public static Integer count = 0;
        public static ThreadLocal threadLocal = new ThreadLocal() {
            protected Integer initialValue() {

                return 0;
            }
        };

        public Integer getNum() {
            int count = threadLocal.get() + 1;
            threadLocal.set(count);
            return count;
        }
    }

    public static class ThreadDemo extends Thread{
        private Res res;

        public ThreadDemo(Res res) {
            this.res = res;
        }
        @Override
        public void run() {
            super.run();
            for (int i = 0; i