zoukankan      html  css  js  c++  java
  • synchronized同步代码块锁释放

    今天发现自己写的线上程序出现数据库不能同步的问题,查看日志已经停止记录,随后使用jstack查看线程的运行状况,发现有个同步线程锁住了。

    以下是jstack -l 637  问题线程的内容。

    "schedulerJob-t-291" #314 daemon prio=5 os_prio=0 tid=0x00007f7d64844800 nid=0x3d5 runnable [0x00007f7d3a107000]
       java.lang.Thread.State: RUNNABLE
    	at java.net.SocketInputStream.socketRead0(Native Method)
    	at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
    	at java.net.SocketInputStream.read(SocketInputStream.java:171)
    	at java.net.SocketInputStream.read(SocketInputStream.java:141)
    	at com.mysql.cj.core.io.ReadAheadInputStream.fill(ReadAheadInputStream.java:101)
    	at com.mysql.cj.core.io.ReadAheadInputStream.readFromUnderlyingStreamIfNecessary(ReadAheadInputStream.java:144)
    	at com.mysql.cj.core.io.ReadAheadInputStream.read(ReadAheadInputStream.java:174)
    	- locked <0x00000000f13c2050> (a com.mysql.cj.core.io.ReadAheadInputStream)
    	at java.io.FilterInputStream.read(FilterInputStream.java:133)
    	at com.mysql.cj.core.io.FullReadInputStream.readFully(FullReadInputStream.java:58)
    	at com.mysql.cj.mysqla.io.SimplePacketReader.readHeader(SimplePacketReader.java:60)
    
         ..........
    at org.springframework.data.repository.core.support.SurroundingTransactionDetectorMethodInterceptor.invoke(SurroundingTransactionDetectorMethodInterceptor.java:61) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:212) at com.sun.proxy.$Proxy91.saveAll(Unknown Source) at com.chenerzhu.crawler.proxy.pool.service.impl.ProxyIpServiceImpl.saveAll(ProxyIpServiceImpl.java:51) at com.chenerzhu.crawler.proxy.pool.job.scheduler.SyncDbSchedulerJob$1.call(SyncDbSchedulerJob.java:95) - locked <0x00000000f0745c78> (a java.lang.Class for com.chenerzhu.crawler.proxy.pool.job.scheduler.SyncDbSchedulerJob) at com.chenerzhu.crawler.proxy.pool.job.scheduler.SyncDbSchedulerJob$1.call(SyncDbSchedulerJob.java:55) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Locked ownable synchronizers: - <0x00000000f1cb9350> (a java.util.concurrent.ThreadPoolExecutor$Worker)

    查看代码发现代码中有这么一段

    FutureTask task = new FutureTask(new Callable<ProxyIp>() {
                            @Override
          public ProxyIp call() {
             ......
              synchronized (SyncDbSchedulerJob.class){
                  proxyIpService.saveAll(availableIpList);
                  availableIpList.clear();
             }
            ........
          }
    }
    
    ........
    
    try {
                ProxyIp proxyIp = proxyIpFuture.get(10, TimeUnit.MINUTES);
                if(proxyIp!=null){
                        proxyIpList.add(proxyIp);
                 }            
         } catch (InterruptedException e) {
           log.error("Interrupted ", e); 
        } catch (Exception e) {
           log.error("error:", e);
    }        
    

    FutureTask中的synchronized批量保存数据,而Future获取使用了超时限制10分钟,由于数据量过大,同步时间超出10分钟了,停止了执行,而synchronized还未释放锁。导致线程锁住了。

    最后通过减少每一次批量执行的数据到1000条,成功使synchronized代码块执行完释放锁。

    ===================================================================

    总结下使用synchronized同步锁释放的时机。我们知道程序执行进入同步代码块中monitorenter代表尝试获取锁,退出代码块monitorexit代表释放锁。而在程序中,是无法显式释放对同步监视器的锁的,而会在如下4种情况下释放锁。

    1、当前线程的同步方法、代码块执行结束的时候释放

    2、当前线程在同步方法、同步代码块中遇到break 、 return 终于该代码块或者方法的时候释放。

    3、出现未处理的error或者exception导致异常结束的时候释放

    4、程序执行了 同步对象 wait 方法 ,当前线程暂停,释放锁

    在以下两种情况不会释放锁。

    1、代码块中使用了 Thread.sleep()  Thread.yield() 这些方法暂停线程的执行,不会释放。

    2、线程执行同步代码块时,其他线程调用 suspend 方法将该线程挂起,该线程不会释放锁 ,所以我们应该避免使用 suspend 和 resume 来控制线程 。

  • 相关阅读:
    关于SQLServer数据库中字段值为NULL,取出来该字段放在DataTable中,判断datatable中该字段值是否为NULL的三种方法
    关于web程序中使用KindEditor向数据库插入带有格式的数据时出现的问题
    使用再生龙对ubuntu16.04系统完全备份与还原
    mysql数据库操作指令汇总
    ubuntu安装supervisor以及使用supervisor启动.net core进程
    c#小数取整
    nuget.server搭建及实际测试
    mysql主从同步+mycat读写分离+.NET程序连接mycat代理
    EasyNVR-流媒体服务详解
    Js实现子窗体给父窗体的元素赋值
  • 原文地址:https://www.cnblogs.com/chenerzhu/p/9690119.html
Copyright © 2011-2022 走看看