MCPcopy Create free account
hub / github.com/e2wugui/zeze / performPrepareQueue

Method performPrepareQueue

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/Dbh2.java:553–563  ·  view source on GitHub ↗
(ConcurrentLinkedQueue<Action0> tmpQueue)

Source from the content-addressed store, hash-verified

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 {

Callers 3

startSplitMethod · 0.95
endSplit2Method · 0.95

Calls 1

runMethod · 0.65

Tested by

no test coverage detected