线程安全的定义
《Java Concurrency In Practice》的作者Brian Goetz 对线程安全是这样理解的,当多个线程访问一个对象时,如果不用考虑这些线程在运行时环境下的调度和交替执行问题,也不需要 进行额外的同步,而调用这个对象的行为都可以获取 正确的结果,那这个对象便是线程安全的。
事实上 Brian Goetz 想表达的意思是 如果某个对象是线程安全的,那么对于使用者来说 ,在使用时就不需要考虑方法间的协调问题,比如说 不需要考虑不能同时写入或者写不能并行的问题,也不需要考虑额外的同步问题,比如不需要额外自己加 synchronized锁
那么它才是线程安全的 可以看出对线程安全的定义还是非常苛刻的
3种典型的线程安全问题
运行结果错误
多个线程操作同一个变量导致的运行结果错误
public class WrongResult {volatile static int i;public static void main(String[] args) throws InterruptedException {Runnable r = new Runnable() {@Overridepublic void run() {for (int j = 0; j < 10000; j++) {i++;}}};Thread thread1 = new Thread(r);thread1.start();Thread thread2 = new Thread(r);thread2.start();thread1.join();thread2.join();System.out.println(i);}}
发布和初始化导致线程安全问题;
我们创建对象进行发布和初始化供其他类或对象使用是常见的操作,但如果我们操作的时间或地点不对 ,就有可能导致线程问题
public class WrongInit {private Map<Integer, String> students;public WrongInit() {new Thread(new Runnable() {@Overridepublic void run() {students = new HashMap<>();students.put(1, "王小美");students.put(2, "钱二宝");students.put(3, "周三");students.put(4, "赵四");}}).start();}public Map<Integer, String> getStudents() {return students;}public static void main(String[] args) throws InterruptedException {WrongInit multiThreadsError6 = new WrongInit();System.out.println(multiThreadsError6.getStudents().get(1));}}
先说结果 会报空指针异常
Exception in thread "main" java.lang.NullPointerExceptionat lesson6.WrongInit.main(WrongInit.java:32)
原因在于 students这个成员变量在构造函数中新建的线程中进行初始化和赋值操作,而线程的启动需要一定的时间,但我们的main并没有sleep 就直接获取数据,此时 students为null。
活跃性问题
活跃性问题 典型的有三种
死锁
死锁是指2个线程之间互相等待对方资源,但同时又互不相让,都想自己先执行
public class MayDeadLock {Object o1 = new Object();Object o2 = new Object();public void thread1() throws InterruptedException {synchronized (o1) {Thread.sleep(500);synchronized (o2) {System.out.println("线程1成功拿到两把锁");}}}public void thread2() throws InterruptedException {synchronized (o2) {Thread.sleep(500);synchronized (o1) {System.out.println("线程2成功拿到两把锁");}}}public static void main(String[] args) {MayDeadLock mayDeadLock = new MayDeadLock();new Thread(new Runnable() {@Overridepublic void run() {try {mayDeadLock.thread1();} catch (InterruptedException e) {e.printStackTrace();}}}).start();new Thread(new Runnable() {@Overridepublic void run() {try {mayDeadLock.thread2();} catch (InterruptedException e) {e.printStackTrace();}}}).start();}}
首先,代码中创建了两个 Object 作为 synchronized 锁的对象,线程 1 先获取 o1 锁,sleep(500) 之后,获取 o2 锁;线程 2 与线程 1 执行顺序相反,先获取 o2 锁,sleep(500) 之后,获取 o1 锁。 假设两个线程几乎同时进入休息,休息完后,线程 1 想获取 o2 锁,线程 2 想获取 o1 锁,这时便发生了死锁,两个线程不主动调和,也不主动退出,就这样死死地等待对方先释放资源,导致程序得不到任何结果也不能停止运行。
活锁
第二种活跃性问题是活锁,活锁与死锁非常相似,也是程序一直等不到结果,但对比于死锁,活锁是活的,什么意思呢?因为正在运行的线程并没有阻塞,它始终在运行中,却一直得不到结果。
举一个例子,假设有一个消息队列,队列里放着各种各样需要被处理的消息,而某个消息由于自身被写错了导致不能被正确处理,执行时会报错,可是队列的重试机制会重新把它放在队列头进行优先重试处理,但这个消息本身无论被执行多少次,都无法被正确处理,每次报错后又会被放到队列头进行重试,周而复始,最终导致线程一直处于忙碌状态,但程序始终得不到结果,便发生了活锁问题。
饥饿
第三个典型的活跃性问题是饥饿,饥饿是指线程需要某些资源时始终得不到,尤其是CPU 资源,就会导致线程一直不能运行而产生的问题。在 Java 中有线程优先级的概念,Java 中优先级分为 1 到 10,1 最低,10 最高。如果我们把某个线程的优先级设置为 1,这是最低的优先级,在这种情况下,这个线程就有可能始终分配不到 CPU 资源,而导致长时间无法运行。或者是某个线程始终持有某个文件的锁,而其他线程想要修改文件就必须先获取锁,这样想要修改文件的线程就会陷入饥饿,长时间不能运行。
