(ConcurrentLinkedQueue<Action0> tmpQueue)
| 551 | } |
| 552 | |
| 553 | private static void performPrepareQueue(ConcurrentLinkedQueue<Action0> tmpQueue) { |
| 554 | if (null != tmpQueue) { |
| 555 | for (var trans : tmpQueue) { |
| 556 | try { |
| 557 | trans.run(); |
| 558 | } catch (Exception e) { |
| 559 | logger.error("", e); |
| 560 | } |
| 561 | } |
| 562 | } |
| 563 | } |
| 564 | |
| 565 | // 开始分桶流程有两个线程需要访问:timer & raft.UserThreadExecutor |
| 566 | private void startSplit(boolean isMove) throws Exception { |
no test coverage detected