synchronized同期コードブロックロック解放
4367 ワード
今日、自分が書いたオンラインプログラムでデータベースが同期できないという問題が発生し、ログの表示が停止したことに気づきました.その後、jstackを使用してスレッドの実行状況を表示し、同期スレッドがロックされていることに気づきました.
以下はjstack-l 637問題スレッドの内容です.
コード発見コードにこのようなセグメントがあることを確認します.
FutureTaskのsynchronizedはデータを一括保存し、Futureはタイムアウト制限を使用して10分を取得したが、データ量が多すぎて同期時間が10分を超え、実行を停止したが、synchronizedはまだロックを解放していない.スレッドがロックされました.
最後に、各バッチで実行されるデータを1000個に減らすことで、synchronizedコードブロックに解放ロックを完了させることに成功した.
===================================================================
synchronized同期ロックを使用して解放するタイミングをまとめます.プログラムが同期コードブロックに入るmonitorenterはロックの取得を試み、コードブロックmonitorexitを終了するとロックの解放を表すことを知っています.一方,プログラムでは同期モニタに対するロックを明示的に解放することはできず,次の4つの場合にロックを解放する.
1、現在のスレッドの同期方法、コードブロックの実行終了時にリリース
2、現在のスレッドは、同期方法、同期コードブロックでbreak、returnがコードブロックまたは方法に遭遇したときに解放される.
3、未処理のerrorまたはexceptionによる異常終了時にリリース
4、プログラムは同期オブジェクトwait方法を実行し、現在のスレッドは一時停止し、ロックを解除する
次の2つの場合、ロックは解放されません.
1.コードブロックにThreadが使用する.sleep() Thread.yield()これらの方法はスレッドの実行を一時停止し、解放されません.
2、スレッドが同期コードブロックを実行するとき、他のスレッドはsuspendメソッドを呼び出してスレッドを一時停止し、このスレッドはロックを解放しないので、suspendとresumeを使用してスレッドを制御することを避けるべきである.
転載先:https://www.cnblogs.com/chenerzhu/p/9690119.html
以下は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() {
@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方法を実行し、現在のスレッドは一時停止し、ロックを解除する
次の2つの場合、ロックは解放されません.
1.コードブロックにThreadが使用する.sleep() Thread.yield()これらの方法はスレッドの実行を一時停止し、解放されません.
2、スレッドが同期コードブロックを実行するとき、他のスレッドはsuspendメソッドを呼び出してスレッドを一時停止し、このスレッドはロックを解放しないので、suspendとresumeを使用してスレッドを制御することを避けるべきである.
転載先:https://www.cnblogs.com/chenerzhu/p/9690119.html