#

Junjie

2025-08-27 190201789934d7b2b4344e0eba6b4a0c2e38f54e

 src/main/java/com/zy/core/thread/impl/NyShuttleThread.java

@@ -762,13 +762,15 @@

    @Override
    public synchronized boolean setTaskNo(Integer taskNo) {
        redisUtil.set(RedisKeyType.SHUTTLE_FLAG.key + shuttleProtocol.getShuttleNo(), taskNo);
        this.shuttleProtocol.setTaskNo(taskNo);
        return true;
    }

    @Override
    public synchronized boolean setSyncTaskNo(Integer taskNo) {
        this.shuttleProtocol.setSyncTaskNo(taskNo);
        redisUtil.setSync(RedisKeyType.SHUTTLE_FLAG.key + shuttleProtocol.getShuttleNo(), taskNo);
        this.shuttleProtocol.setTaskNo(taskNo);
        return true;
    }