Synchronize异常释放锁

秒速五厘米 2022-05-15 01:50 243阅读 0赞

### Synchronize异常释放锁 ###

遇到异常的时候，就会释放锁  
对象锁，并不会影响后续队列任务的执行

### 处理队列 ###

Synchronize处理一个队列，多个任务

任务独立  
任务之间不会相互影响，此时，可以遇到异常  
记录日志，然后，继续执行后续的任务  
最后，等所有的任务都执行完毕，再根据日志处理，发生异常的任务

任务整体  
任务之间存在关联关系，所有的任务是一个整体  
某一个任务执行失败，后续的任务，都会受到影响  
此时，可以直接抛出异常，记录日志，后续的任务不再继续执行  
执行过的任务，可以回滚

抛出异常  
可以抛出打断异常  
也可以抛出运行时异常

package com.bjsxt.base.sync005;
    
    /** * synchronized异常 * */
    public class SyncException { 
    
        private int i = 0;
    
        public synchronized void operation() {
            while (true) {
                try {
                    i++;
                    Thread.sleep(100);
                    System.out.println(Thread.currentThread().getName() + " , i = " + i);
                    if (i == 10) {
                        Integer.parseInt("a");
                        // throw new RuntimeException();
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    System.out.println("log info i=" + i);
                }
            }
        }
    
        public static void main(String[] args) {
    
            final SyncException se = new SyncException();
            Thread t1 = new Thread(new Runnable() {
                @Override
                public void run() {
                    se.operation();
                }
            }, "t1");
            t1.start();
        }
    
    }

运行  
![这里写图片描述][70]  
在第10条出现异常，记录日志  
后续任务，继续执行

### 抛出异常 ###

打断异常

try {
        i++;
        Thread.sleep(100);
        System.out.println(Thread.currentThread().getName() + " , i = " + i);
        if (i == 10) {
            Integer.parseInt("a");
            // throw new RuntimeException();
        }
    } catch (InterruptedException e) {
        e.printStackTrace();
        System.out.println("log info i=" + i);
    }

运行  
![这里写图片描述][70 1]  
运行时异常

try {
        i++;
        Thread.sleep(100);
        System.out.println(Thread.currentThread().getName() + " , i = " + i);
        if (i == 10) {
            Integer.parseInt("a");
            // throw new RuntimeException();
        }
    } catch (Exception e) {
        e.printStackTrace();
        System.out.println("log info i=" + i);
        throw new RuntimeException();
    }

运行  
![这里写图片描述][70 2]  
此时，代码都不会继续往下执行  
可以通过事务，将执行过的任务，就行回滚

[70]: /images/20220515/d34a8fa22ca448c38b15d37ed558bc05.png
[70 1]: /images/20220515/08fee0231ec74393bf868a428636519b.png
[70 2]: /images/20220515/2ead7df0ac7943f98b5045ba14be2bda.png