| | |
| | | result = jedis.setnx(cacheKey, "1");
|
| | | if (result <= 0) {
|
| | | try {
|
| | | System.out.println("__________已有线程在执行");
|
| | | Thread.sleep(50);
|
| | | } catch (InterruptedException e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | | if (System.currentTimeMillis() - startTime > 1000 * 60L) {
|
| | | Constant.waitingThreadSet.remove(Thread.currentThread().getId());
|
| | | System.out.println("__________删除线程");
|
| | | return null;
|
| | | }
|
| | | } else {
|
| | |
| | |
|
| | | if (result > 0) {
|
| | | try {
|
| | | System.out.println("__________放行执行");
|
| | | return joinPoint.proceed();
|
| | | } catch (Throwable e) {
|
| | | e.printStackTrace();
|
| | |
| | | } catch (SecurityException e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | |
|
| | | return joinPoint.proceed();
|
| | | |
| | | }
|
| | |
|
| | | }
|