lxm_library_java/WxJava
1
0
Fork 0
mirror of synced 2025-12-16 20:28:11 +08:00
Code Issues Projects Releases Wiki Activity

🎨 增加加锁的超时时间，避免死循环

Browse Source
This commit is contained in:
Ripic Zhang
2024-03-02 18:11:37 +08:00
committed by GitHub
parent ad6ad003bc
commit fc8d815d6e
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
weixin-java-mp/src/main/java/me/chanjar/weixin/mp/api/impl/BaseWxMpServiceImpl.java
View File

@@ -263,6 +263,7 @@ public abstract class BaseWxMpServiceImpl<H, P> implements WxMpService, RequestH
} }
Lock lock = this.getWxMpConfigStorage().getAccessTokenLock(); Lock lock = this.getWxMpConfigStorage().getAccessTokenLock();
long timeOutMillis = System.currentTimeMillis() + 3000;
boolean locked = false; boolean locked = false;
try { try {
do { do {
@@ -270,6 +271,9 @@ public abstract class BaseWxMpServiceImpl<H, P> implements WxMpService, RequestH
if (!forceRefresh && !this.getWxMpConfigStorage().isAccessTokenExpired()) { if (!forceRefresh && !this.getWxMpConfigStorage().isAccessTokenExpired()) {
return this.getWxMpConfigStorage().getAccessToken(); return this.getWxMpConfigStorage().getAccessToken();
} }
if (!locked && System.currentTimeMillis() > timeOutMillis) {
throw new InterruptedException("获取accessToken超时：获取时间超时");
}
} while (!locked); } while (!locked);
String response; String response;