ThreadPoolExecutor自定义线程池|拒绝策略|线程工厂|统一捕获异常

线程池的7大参数含义介绍

corePoolSize：池中一直保持的线程的数量。

maximumPoolSize：池中允许的最大的线程数。

keepAliveTime：当线程数大于核心线程数的时候，线程在最大多长时间没有接到新任务就会终止释放，最终线程池维持在 corePoolSize 大。

unit：时间单位。

workQueue：阻塞队列，用来存储等待执行的任务，如果当前对线程的需求超过了 corePoolSize 大小，就会放在这里等待空闲线程执行。

threadFactory：创建线程的工厂，比如指定线程名等。

handler：拒绝策略，如果线程满了，线程池就会使用拒绝策略。

5、

运行流程：

1、线程池创建，准备好 core 数量的核心线程，准备接受任务

2、新的任务进来，用 core 准备好的空闲线程执行。

(1) 、core 满了，就将再进来的任务放入阻塞队列中。空闲的 core 就会自己去阻塞队列获取任务执行

(2) 、阻塞队列满了，就直接开新线程执行，最大只能开到 max 指定的数量

(3) 、max 都执行好了。Max-core 数量空闲的线程会在 keepAliveTime 指定的时间后自动销毁。最终保持到 core 大小

(4) 、如果线程数开到了 max 的数量，还有新任务进来，就会使用 reject 指定的拒绝策略进行处理

3、所有的线程创建都是由指定的 factory 创建的
————————————

自定义线程工厂:

package org.jd.data.netty.big.window.chat.frame.ui.controller.center;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.ThreadFactory;

@Slf4j
public class SSOCustomerThreadFactory implements ThreadFactory {
    public SSOCustomerThreadFactory() {
    }

    @Override
    public Thread newThread(Runnable task) {
        // 获取当前任务的名称
        Thread thread = new Thread(task, task.getClass().getName());
        thread.setUncaughtExceptionHandler(new SSOCustomerUncaughtExceptionHandler());
        return thread;
    }

    /**
     * 自定义统一处理线程池异常:日志处理
     */
    private static class SSOCustomerUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler {
        @Override
        public void uncaughtException(Thread t, Throwable e) {
            System.err.println("异常处理器捕获到了异常: "+"current thread id : " + t.getId() + "  | name : " + t.getName() + " | status : " + t.getState() + " |  error : " + e.getMessage() + " stack info : " + t.getStackTrace());
        }
    }
}

自定义线程池饱和策略处理器:

package org.jd.data.netty.big.window.chat.frame.ui.controller.center;

import cn.hutool.json.JSONUtil;
import javafx.concurrent.Worker;
import org.jd.data.netty.big.window.chat.entity.SSOUser;
import org.jd.data.netty.big.window.chat.frame.ui.task.WorkerTask;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * 自定义线程池饱和时处理策略
 */
public class SSORejectedExecutionHandler implements RejectedExecutionHandler {
    final Map<String, Runnable> tempMap = new ConcurrentHashMap<>();

    /**
     * 具体实现方法，一般上线后，会把多余的线程任务，保存到日志或写库，这里模拟尝试几种处理
     *
     * @param r   进入该处的任务一定是被丢弃的
     * @param executor
     */
    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        WorkerTask worker = (WorkerTask) r;

        // 模拟写日志
        System.err.println(worker.getId() + " 被丢弃! 此时消息为: "+ JSONUtil.toJsonStr(worker));
        tempMap.put(worker.getId(), r); // 被丢弃的任务加到tempMap中去
        // 重新放入队列里执行
        try {
            System.out.println("重新放入队列前的队列大小为: "+executor.getQueue().size());
            executor.getQueue().put(r);
            System.out.println("重新放入队列后的队列大小为: "+executor.getQueue().size());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }
}

自定义线程池

package org.jd.data.netty.big.window.chat.frame.ui.controller.center;
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.*;
/**
 * 设计模式: 单例模式
 * 自定义线程池: 实现业务需求:
 * 可以获取线程池内部细节,对排查程序故障有很大的好处
 */
@Slf4j
public final class SSOCustomerThreadPoolExecutor extends ThreadPoolExecutor {

    private static final int corePoolSize = 4;
    private static final long keepAliveTime = 10;
    private static final int maximumPoolSize = 10;
    private static final TimeUnit unit = TimeUnit.MILLISECONDS;  // 微秒
    private static final BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(10); // 队列容量
    private static final ThreadFactory threadFactory = new SSOCustomerThreadFactory();

    private static class SSOCustomerThreadPoolExecutorHandler {
        //static int maximumPoolSize = Runtime.getRuntime().availableProcessors();
        private static SSOCustomerThreadPoolExecutor newInstance = new SSOCustomerThreadPoolExecutor(maximumPoolSize * 2, threadFactory);
    }

    public static SSOCustomerThreadPoolExecutor newInstance() {
        return SSOCustomerThreadPoolExecutor.SSOCustomerThreadPoolExecutorHandler.newInstance;
    }


    private SSOCustomerThreadPoolExecutor(int maximumPoolSize, ThreadFactory threadFactory) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory,new SSORejectedExecutionHandler());
    }

    @Override
    protected void beforeExecute(Thread task, Runnable r) {
        Runtime runtime = Runtime.getRuntime();
        int cupNum = runtime.availableProcessors();// 获取可以的CUP数量
        long freeMemory = runtime.freeMemory(); // 空闲内存 kb;
        long maxMemory = runtime.maxMemory();
        long totalMemory = runtime.totalMemory();
        System.out.println("current name: " + task.getName() + " | beforeExecute 可以的CPU数量: " + cupNum + " | 空闲内存: " + freeMemory + " | 最大内存: " + maxMemory + "  | 总内存: " + totalMemory);
    }

    @Override
    protected void afterExecute(Runnable task, Throwable t) {
        System.out.println("afterExecute Thread name : " + task.getClass().getSimpleName()+ " | current thread status :" + Thread.currentThread().getState()
                + " current thread id : " + Thread.currentThread().getId() + " | afterExecute poolSize : "
                + this.getPoolSize() + " | threadPool task num : "
                + this.getTaskCount() + " | finished task num: "
                + this.getCompletedTaskCount() + " | not finished task num: " + (this.getTaskCount() - this.getCompletedTaskCount()));
    }


}

测试:

package org.jd.data.netty.big.window.chat.frame.ui.task;

import cn.hutool.json.JSONUtil;

/**
 * 工作任务
 */
public class WorkerTask implements Runnable {
    // 任务编号: 共享资源
    private  String id;
    private  String workName;

    public String getId() {
        return id;
    }

    public String getWorkName() {
        return workName;
    }

    public  void setWorkName(String workName) {
        this.workName = workName;
    }

    // 运行其他线程修改该值,但是该共享资源时线程安装的,该变量共享资源对其他线程可见
    public  void setId(String id) {
        this.id = id;
    }

    public WorkerTask() {
        super();
    }

    public WorkerTask(String id) {
        super();
        this.id = id;
    }


    @Override
    public void run() {
        try {
            Thread.sleep(100);
            if (!(this.getWorkName().split("-")[1].equals(this.getId()))) {
                System.err.println("当前任务：" + this.getWorkName().split("-")[1] +"    <id>: "+ this.getId()+" | 消息为: " + JSONUtil.toJsonStr(this) + " 数据异常！");
            } else {
                System.out.println("当前任务：" + this.getId() + " | 消息为: " + JSONUtil.toJsonStr(this) + " 正常执行！");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

package org.jd.data.netty.big.window.chat.frame.ui.controller.center;

import cn.hutool.json.JSONUtil;
import org.jd.data.netty.big.window.chat.frame.ui.task.WorkerTask;

import java.util.List;

public class SSOCustomerThreadPoolExecutorTest {

    public static void main(String args[]) {
        SSOCustomerThreadPoolExecutor executor = SSOCustomerThreadPoolExecutor.newInstance();
        for (int i = 0; i < 100000; i++) {
            WorkerTask workerTask = new WorkerTask();
            workerTask.setId(String.valueOf(i));
            workerTask.setWorkName("task-" + i);
            executor.execute(workerTask);
          /*  try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }*/
        }
        List<Runnable> resultList = executor.shutdownNow();
        System.out.println("未完成的任务: " + JSONUtil.toJsonStr(resultList));
    }
}

package org.jd.data.netty.big.window.chat.frame.ui.task;

import cn.hutool.json.JSONUtil;

/**
 * 工作任务
 */
public class WorkerTask implements Runnable {
    // 任务编号: 共享资源
    private  String id;
    private  String workName;

    public String getId() {
        return id;
    }

    public String getWorkName() {
        return workName;
    }

    public  void setWorkName(String workName) {
        this.workName = workName;
    }

    // 运行其他线程修改该值,但是该共享资源时线程安装的,该变量共享资源对其他线程可见
    public  void setId(String id) {
        this.id = id;
    }

    public WorkerTask() {
        super();
    }

    public WorkerTask(String id) {
        super();
        this.id = id;
    }


    @Override
    public void run() {
        try {
            Thread.sleep(100);
            if (!(this.getWorkName().split("-")[1].equals(this.getId()))) {
                System.err.println("当前任务：" + this.getWorkName().split("-")[1] +"    <id>: "+ this.getId()+" | 消息为: " + JSONUtil.toJsonStr(this) + " 数据异常！");
            } else {
                System.out.println("当前任务：" + this.getId() + " | 消息为: " + JSONUtil.toJsonStr(this) + " 正常执行！");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

"C:\Program Files\Java\jdk1.8.0_221\bin\java.exe" "-javaagent:D:\idea_worker\IntelliJ IDEA 2020.2\lib\idea_rt.jar=59177:D:\idea_worker\IntelliJ IDEA 2020.2\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_221\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_221\jre\lib\rt.jar;D:\program_file\SSO-ReactiveServer-Sysetem\SSO-JRootPaneWindow-provider\target\classes;D:\maven_worker\Respository\Respository\cn\hutool\hutool-all\5.8.18\hutool-all-5.8.18.jar;D:\maven_worker\Respository\Respository\org\ehcache\ehcache\3.10.8\ehcache-3.10.8.jar;D:\maven_worker\Respository\Respository\javax\cache\cache-api\1.1.1\cache-api-1.1.1.jar;D:\maven_worker\Respository\Respository\org\slf4j\slf4j-api\1.7.30\slf4j-api-1.7.30.jar;D:\maven_worker\Respository\Respository\org\glassfish\jaxb\jaxb-runtime\2.3.2\jaxb-runtime-2.3.2.jar;D:\maven_worker\Respository\Respository\jakarta\xml\bind\jakarta.xml.bind-api\2.3.3\jakarta.xml.bind-api-2.3.3.jar;D:\maven_worker\Respository\Respository\org\glassfish\jaxb\txw2\2.3.2\txw2-2.3.2.jar;D:\maven_worker\Respository\Respository\com\sun\istack\istack-commons-runtime\3.0.8\istack-commons-runtime-3.0.8.jar;D:\maven_worker\Respository\Respository\org\jvnet\staxex\stax-ex\1.8.1\stax-ex-1.8.1.jar;D:\maven_worker\Respository\Respository\com\sun\xml\fastinfoset\FastInfoset\1.2.16\FastInfoset-1.2.16.jar;D:\maven_worker\Respository\Respository\jakarta\activation\jakarta.activation-api\1.2.2\jakarta.activation-api-1.2.2.jar;D:\maven_worker\Respository\Respository\org\jfree\jfreechart\1.5.4\jfreechart-1.5.4.jar;D:\maven_worker\Respository\Respository\mysql\mysql-connector-java\8.0.28\mysql-connector-java-8.0.28.jar;D:\maven_worker\Respository\Respository\com\baomidou\mybatis-plus\3.5.3.1\mybatis-plus-3.5.3.1.jar;D:\maven_worker\Respository\Respository\com\baomidou\mybatis-plus-extension\3.5.3.1\mybatis-plus-extension-3.5.3.1.jar;D:\maven_worker\Respository\Respository\com\baomidou\mybatis-plus-core\3.5.3.1\mybatis-plus-core-3.5.3.1.jar;D:\maven_worker\Respository\Respository\com\baomidou\mybatis-plus-annotation\3.5.3.1\mybatis-plus-annotation-3.5.3.1.jar;D:\maven_worker\Respository\Respository\com\github\jsqlparser\jsqlparser\4.4\jsqlparser-4.4.jar;D:\maven_worker\Respository\Respository\org\mybatis\mybatis\3.5.10\mybatis-3.5.10.jar;D:\maven_worker\Respository\Respository\org\mybatis\mybatis-spring\2.0.7\mybatis-spring-2.0.7.jar;D:\maven_worker\Respository\Respository\com\alibaba\druid\1.2.16\druid-1.2.16.jar;D:\maven_worker\Respository\Respository\org\redisson\redisson\3.23.0\redisson-3.23.0.jar;D:\maven_worker\Respository\Respository\io\netty\netty-common\4.1.48.Final\netty-common-4.1.48.Final.jar;D:\maven_worker\Respository\Respository\io\netty\netty-codec\4.1.48.Final\netty-codec-4.1.48.Final.jar;D:\maven_worker\Respository\Respository\io\netty\netty-buffer\4.1.48.Final\netty-buffer-4.1.48.Final.jar;D:\maven_worker\Respository\Respository\io\netty\netty-transport\4.1.48.Final\netty-transport-4.1.48.Final.jar;D:\maven_worker\Respository\Respository\io\netty\netty-resolver\4.1.48.Final\netty-resolver-4.1.48.Final.jar;D:\maven_worker\Respository\Respository\io\netty\netty-resolver-dns\4.1.48.Final\netty-resolver-dns-4.1.48.Final.jar;D:\maven_worker\Respository\Respository\io\netty\netty-codec-dns\4.1.48.Final\netty-codec-dns-4.1.48.Final.jar;D:\maven_worker\Respository\Respository\io\netty\netty-handler\4.1.48.Final\netty-handler-4.1.48.Final.jar;D:\maven_worker\Respository\Respository\io\projectreactor\reactor-core\3.3.4.RELEASE\reactor-core-3.3.4.RELEASE.jar;D:\maven_worker\Respository\Respository\org\reactivestreams\reactive-streams\1.0.3\reactive-streams-1.0.3.jar;D:\maven_worker\Respository\Respository\io\reactivex\rxjava3\rxjava\3.1.6\rxjava-3.1.6.jar;D:\maven_worker\Respository\Respository\org\jboss\marshalling\jboss-marshalling\2.0.11.Final\jboss-marshalling-2.0.11.Final.jar;D:\maven_worker\Respository\Respository\org\jboss\marshalling\jboss-marshalling-river\2.0.11.Final\jboss-marshalling-river-2.0.11.Final.jar;D:\maven_worker\Respository\Respository\com\esotericsoftware\kryo\5.5.0\kryo-5.5.0.jar;D:\maven_worker\Respository\Respository\com\esotericsoftware\reflectasm\1.11.9\reflectasm-1.11.9.jar;D:\maven_worker\Respository\Respository\org\objenesis\objenesis\3.3\objenesis-3.3.jar;D:\maven_worker\Respository\Respository\com\esotericsoftware\minlog\1.3.1\minlog-1.3.1.jar;D:\maven_worker\Respository\Respository\com\fasterxml\jackson\core\jackson-annotations\2.10.3\jackson-annotations-2.10.3.jar;D:\maven_worker\Respository\Respository\com\fasterxml\jackson\dataformat\jackson-dataformat-yaml\2.10.3\jackson-dataformat-yaml-2.10.3.jar;D:\maven_worker\Respository\Respository\org\yaml\snakeyaml\1.25\snakeyaml-1.25.jar;D:\maven_worker\Respository\Respository\com\fasterxml\jackson\core\jackson-core\2.10.3\jackson-core-2.10.3.jar;D:\maven_worker\Respository\Respository\com\fasterxml\jackson\core\jackson-databind\2.10.3\jackson-databind-2.10.3.jar;D:\maven_worker\Respository\Respository\net\bytebuddy\byte-buddy\1.10.8\byte-buddy-1.10.8.jar;D:\maven_worker\Respository\Respository\org\jodd\jodd-bean\5.1.6\jodd-bean-5.1.6.jar;D:\maven_worker\Respository\Respository\org\jodd\jodd-core\5.1.6\jodd-core-5.1.6.jar;D:\maven_worker\Respository\Respository\org\ini4j\ini4j\0.5.4\ini4j-0.5.4.jar" org.jd.data.netty.big.window.chat.frame.ui.controller.center.SSOCustomerThreadPoolExecutorTest
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
当前任务：17 | 消息为: {"id":"17","workName":"task-17"} 正常执行！
当前任务：18 | 消息为: {"id":"18","workName":"task-18"} 正常执行！
当前任务：27 | 消息为: {"id":"27","workName":"task-27"} 正常执行！
当前任务：20 | 消息为: {"id":"20","workName":"task-20"} 正常执行！
当前任务：24 | 消息为: {"id":"24","workName":"task-24"} 正常执行！
当前任务：16 | 消息为: {"id":"16","workName":"task-16"} 正常执行！
当前任务：14 | 消息为: {"id":"14","workName":"task-14"} 正常执行！
当前任务：3 | 消息为: {"id":"3","workName":"task-3"} 正常执行！
当前任务：15 | 消息为: {"id":"15","workName":"task-15"} 正常执行！
当前任务：22 | 消息为: {"id":"22","workName":"task-22"} 正常执行！
当前任务：29 | 消息为: {"id":"29","workName":"task-29"} 正常执行！
当前任务：2 | 消息为: {"id":"2","workName":"task-2"} 正常执行！
当前任务：1 | 消息为: {"id":"1","workName":"task-1"} 正常执行！
当前任务：26 | 消息为: {"id":"26","workName":"task-26"} 正常执行！
当前任务：28 | 消息为: {"id":"28","workName":"task-28"} 正常执行！
当前任务：25 | 消息为: {"id":"25","workName":"task-25"} 正常执行！
当前任务：23 | 消息为: {"id":"23","workName":"task-23"} 正常执行！
当前任务：19 | 消息为: {"id":"19","workName":"task-19"} 正常执行！
重新放入队列前的队列大小为: 8
当前任务：0 | 消息为: {"id":"0","workName":"task-0"} 正常执行！
当前任务：21 | 消息为: {"id":"21","workName":"task-21"} 正常执行！
重新放入队列后的队列大小为: 0
重新放入队列前的队列大小为: 2
重新放入队列后的队列大小为: 3
重新放入队列前的队列大小为: 10
30 被丢弃! 此时消息为: {"id":"30","workName":"task-30"}
42 被丢弃! 此时消息为: {"id":"42","workName":"task-42"}
50 被丢弃! 此时消息为: {"id":"50","workName":"task-50"}
当前任务：11 | 消息为: {"id":"11","workName":"task-11"} 正常执行！
当前任务：12 | 消息为: {"id":"12","workName":"task-12"} 正常执行！
重新放入队列后的队列大小为: 10
当前任务：34 | 消息为: {"id":"34","workName":"task-34"} 正常执行！
当前任务：35 | 消息为: {"id":"35","workName":"task-35"} 正常执行！
当前任务：39 | 消息为: {"id":"39","workName":"task-39"} 正常执行！
当前任务：8 | 消息为: {"id":"8","workName":"task-8"} 正常执行！
当前任务：10 | 消息为: {"id":"10","workName":"task-10"} 正常执行！
当前任务：38 | 消息为: {"id":"38","workName":"task-38"} 正常执行！
重新放入队列前的队列大小为: 5
当前任务：30 | 消息为: {"id":"30","workName":"task-30"} 正常执行！
当前任务：7 | 消息为: {"id":"7","workName":"task-7"} 正常执行！
当前任务：5 | 消息为: {"id":"5","workName":"task-5"} 正常执行！
当前任务：32 | 消息为: {"id":"32","workName":"task-32"} 正常执行！
重新放入队列后的队列大小为: 5
当前任务：13 | 消息为: {"id":"13","workName":"task-13"} 正常执行！
当前任务：33 | 消息为: {"id":"33","workName":"task-33"} 正常执行！
当前任务：36 | 消息为: {"id":"36","workName":"task-36"} 正常执行！
当前任务：6 | 消息为: {"id":"6","workName":"task-6"} 正常执行！
当前任务：31 | 消息为: {"id":"31","workName":"task-31"} 正常执行！
当前任务：4 | 消息为: {"id":"4","workName":"task-4"} 正常执行！
当前任务：9 | 消息为: {"id":"9","workName":"task-9"} 正常执行！
重新放入队列前的队列大小为: 4
当前任务：37 | 消息为: {"id":"37","workName":"task-37"} 正常执行！
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 10
52 被丢弃! 此时消息为: {"id":"52","workName":"task-52"}
62 被丢弃! 此时消息为: {"id":"62","workName":"task-62"}
70 被丢弃! 此时消息为: {"id":"70","workName":"task-70"}
当前任务：55 | 消息为: {"id":"55","workName":"task-55"} 正常执行！
当前任务：50 | 消息为: {"id":"50","workName":"task-50"} 正常执行！
当前任务：42 | 消息为: {"id":"42","workName":"task-42"} 正常执行！
当前任务：58 | 消息为: {"id":"58","workName":"task-58"} 正常执行！
重新放入队列后的队列大小为: 10
当前任务：53 | 消息为: {"id":"53","workName":"task-53"} 正常执行！
当前任务：44 | 消息为: {"id":"44","workName":"task-44"} 正常执行！
当前任务：51 | 消息为: {"id":"51","workName":"task-51"} 正常执行！
当前任务：40 | 消息为: {"id":"40","workName":"task-40"} 正常执行！
当前任务：56 | 消息为: {"id":"56","workName":"task-56"} 正常执行！
当前任务：41 | 消息为: {"id":"41","workName":"task-41"} 正常执行！
当前任务：43 | 消息为: {"id":"43","workName":"task-43"} 正常执行！
当前任务：57 | 消息为: {"id":"57","workName":"task-57"} 正常执行！
当前任务：46 | 消息为: {"id":"46","workName":"task-46"} 正常执行！
当前任务：45 | 消息为: {"id":"45","workName":"task-45"} 正常执行！
当前任务：49 | 消息为: {"id":"49","workName":"task-49"} 正常执行！
当前任务：47 | 消息为: {"id":"47","workName":"task-47"} 正常执行！
当前任务：59 | 消息为: {"id":"59","workName":"task-59"} 正常执行！
当前任务：54 | 消息为: {"id":"54","workName":"task-54"} 正常执行！
当前任务：52 | 消息为: {"id":"52","workName":"task-52"} 正常执行！
当前任务：48 | 消息为: {"id":"48","workName":"task-48"} 正常执行！
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 1
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 8
重新放入队列前的队列大小为: 10
74 被丢弃! 此时消息为: {"id":"74","workName":"task-74"}
87 被丢弃! 此时消息为: {"id":"87","workName":"task-87"}
90 被丢弃! 此时消息为: {"id":"90","workName":"task-90"}
当前任务：62 | 消息为: {"id":"62","workName":"task-62"} 正常执行！
当前任务：76 | 消息为: {"id":"76","workName":"task-76"} 正常执行！
当前任务：61 | 消息为: {"id":"61","workName":"task-61"} 正常执行！
当前任务：68 | 消息为: {"id":"68","workName":"task-68"} 正常执行！
当前任务：71 | 消息为: {"id":"71","workName":"task-71"} 正常执行！
当前任务：75 | 消息为: {"id":"75","workName":"task-75"} 正常执行！
当前任务：79 | 消息为: {"id":"79","workName":"task-79"} 正常执行！
当前任务：67 | 消息为: {"id":"67","workName":"task-67"} 正常执行！
当前任务：78 | 消息为: {"id":"78","workName":"task-78"} 正常执行！
当前任务：65 | 消息为: {"id":"65","workName":"task-65"} 正常执行！
当前任务：72 | 消息为: {"id":"72","workName":"task-72"} 正常执行！
当前任务：74 | 消息为: {"id":"74","workName":"task-74"} 正常执行！
当前任务：63 | 消息为: {"id":"63","workName":"task-63"} 正常执行！
当前任务：69 | 消息为: {"id":"69","workName":"task-69"} 正常执行！
当前任务：66 | 消息为: {"id":"66","workName":"task-66"} 正常执行！
当前任务：64 | 消息为: {"id":"64","workName":"task-64"} 正常执行！
当前任务：70 | 消息为: {"id":"70","workName":"task-70"} 正常执行！
当前任务：73 | 消息为: {"id":"73","workName":"task-73"} 正常执行！
当前任务：60 | 消息为: {"id":"60","workName":"task-60"} 正常执行！
重新放入队列后的队列大小为: 10
当前任务：77 | 消息为: {"id":"77","workName":"task-77"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 10
103 被丢弃! 此时消息为: {"id":"103","workName":"task-103"}
110 被丢弃! 此时消息为: {"id":"110","workName":"task-110"}
当前任务：96 | 消息为: {"id":"96","workName":"task-96"} 正常执行！
当前任务：99 | 消息为: {"id":"99","workName":"task-99"} 正常执行！
重新放入队列后的队列大小为: 10
当前任务：85 | 消息为: {"id":"85","workName":"task-85"} 正常执行！
当前任务：95 | 消息为: {"id":"95","workName":"task-95"} 正常执行！
当前任务：97 | 消息为: {"id":"97","workName":"task-97"} 正常执行！
当前任务：98 | 消息为: {"id":"98","workName":"task-98"} 正常执行！
当前任务：91 | 消息为: {"id":"91","workName":"task-91"} 正常执行！
当前任务：88 | 消息为: {"id":"88","workName":"task-88"} 正常执行！
当前任务：86 | 消息为: {"id":"86","workName":"task-86"} 正常执行！
当前任务：83 | 消息为: {"id":"83","workName":"task-83"} 正常执行！
当前任务：92 | 消息为: {"id":"92","workName":"task-92"} 正常执行！
当前任务：89 | 消息为: {"id":"89","workName":"task-89"} 正常执行！
重新放入队列前的队列大小为: 5
当前任务：87 | 消息为: {"id":"87","workName":"task-87"} 正常执行！
当前任务：84 | 消息为: {"id":"84","workName":"task-84"} 正常执行！
当前任务：94 | 消息为: {"id":"94","workName":"task-94"} 正常执行！
当前任务：80 | 消息为: {"id":"80","workName":"task-80"} 正常执行！
当前任务：93 | 消息为: {"id":"93","workName":"task-93"} 正常执行！
当前任务：81 | 消息为: {"id":"81","workName":"task-81"} 正常执行！
当前任务：90 | 消息为: {"id":"90","workName":"task-90"} 正常执行！
当前任务：82 | 消息为: {"id":"82","workName":"task-82"} 正常执行！
重新放入队列后的队列大小为: 1
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 10
112 被丢弃! 此时消息为: {"id":"112","workName":"task-112"}
125 被丢弃! 此时消息为: {"id":"125","workName":"task-125"}
130 被丢弃! 此时消息为: {"id":"130","workName":"task-130"}
当前任务：109 | 消息为: {"id":"109","workName":"task-109"} 正常执行！
当前任务：106 | 消息为: {"id":"106","workName":"task-106"} 正常执行！
当前任务：102 | 消息为: {"id":"102","workName":"task-102"} 正常执行！
当前任务：110 | 消息为: {"id":"110","workName":"task-110"} 正常执行！
当前任务：115 | 消息为: {"id":"115","workName":"task-115"} 正常执行！
当前任务：108 | 消息为: {"id":"108","workName":"task-108"} 正常执行！
当前任务：116 | 消息为: {"id":"116","workName":"task-116"} 正常执行！
当前任务：113 | 消息为: {"id":"113","workName":"task-113"} 正常执行！
当前任务：111 | 消息为: {"id":"111","workName":"task-111"} 正常执行！
当前任务：101 | 消息为: {"id":"101","workName":"task-101"} 正常执行！
当前任务：104 | 消息为: {"id":"104","workName":"task-104"} 正常执行！
当前任务：100 | 消息为: {"id":"100","workName":"task-100"} 正常执行！
当前任务：107 | 消息为: {"id":"107","workName":"task-107"} 正常执行！
当前任务：117 | 消息为: {"id":"117","workName":"task-117"} 正常执行！
当前任务：118 | 消息为: {"id":"118","workName":"task-118"} 正常执行！
当前任务：114 | 消息为: {"id":"114","workName":"task-114"} 正常执行！
当前任务：119 | 消息为: {"id":"119","workName":"task-119"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：112 | 消息为: {"id":"112","workName":"task-112"} 正常执行！
当前任务：105 | 消息为: {"id":"105","workName":"task-105"} 正常执行！
当前任务：103 | 消息为: {"id":"103","workName":"task-103"} 正常执行！
重新放入队列前的队列大小为: 2
重新放入队列后的队列大小为: 3
重新放入队列前的队列大小为: 10
142 被丢弃! 此时消息为: {"id":"142","workName":"task-142"}
150 被丢弃! 此时消息为: {"id":"150","workName":"task-150"}
当前任务：130 | 消息为: {"id":"130","workName":"task-130"} 正常执行！
当前任务：139 | 消息为: {"id":"139","workName":"task-139"} 正常执行！
当前任务：136 | 消息为: {"id":"136","workName":"task-136"} 正常执行！
当前任务：129 | 消息为: {"id":"129","workName":"task-129"} 正常执行！
当前任务：135 | 消息为: {"id":"135","workName":"task-135"} 正常执行！
当前任务：133 | 消息为: {"id":"133","workName":"task-133"} 正常执行！
当前任务：124 | 消息为: {"id":"124","workName":"task-124"} 正常执行！
当前任务：128 | 消息为: {"id":"128","workName":"task-128"} 正常执行！
当前任务：134 | 消息为: {"id":"134","workName":"task-134"} 正常执行！
当前任务：120 | 消息为: {"id":"120","workName":"task-120"} 正常执行！
当前任务：121 | 消息为: {"id":"121","workName":"task-121"} 正常执行！
当前任务：132 | 消息为: {"id":"132","workName":"task-132"} 正常执行！
当前任务：138 | 消息为: {"id":"138","workName":"task-138"} 正常执行！
当前任务：122 | 消息为: {"id":"122","workName":"task-122"} 正常执行！
当前任务：127 | 消息为: {"id":"127","workName":"task-127"} 正常执行！
当前任务：137 | 消息为: {"id":"137","workName":"task-137"} 正常执行！
当前任务：125 | 消息为: {"id":"125","workName":"task-125"} 正常执行！
当前任务：131 | 消息为: {"id":"131","workName":"task-131"} 正常执行！
当前任务：123 | 消息为: {"id":"123","workName":"task-123"} 正常执行！
当前任务：126 | 消息为: {"id":"126","workName":"task-126"} 正常执行！
重新放入队列后的队列大小为: 10
重新放入队列前的队列大小为: 2
重新放入队列后的队列大小为: 3
重新放入队列前的队列大小为: 10
162 被丢弃! 此时消息为: {"id":"162","workName":"task-162"}
170 被丢弃! 此时消息为: {"id":"170","workName":"task-170"}
当前任务：154 | 消息为: {"id":"154","workName":"task-154"} 正常执行！
当前任务：151 | 消息为: {"id":"151","workName":"task-151"} 正常执行！
当前任务：157 | 消息为: {"id":"157","workName":"task-157"} 正常执行！
当前任务：147 | 消息为: {"id":"147","workName":"task-147"} 正常执行！
当前任务：140 | 消息为: {"id":"140","workName":"task-140"} 正常执行！
当前任务：142 | 消息为: {"id":"142","workName":"task-142"} 正常执行！
当前任务：153 | 消息为: {"id":"153","workName":"task-153"} 正常执行！
当前任务：159 | 消息为: {"id":"159","workName":"task-159"} 正常执行！
当前任务：149 | 消息为: {"id":"149","workName":"task-149"} 正常执行！
当前任务：148 | 消息为: {"id":"148","workName":"task-148"} 正常执行！
当前任务：152 | 消息为: {"id":"152","workName":"task-152"} 正常执行！
当前任务：143 | 消息为: {"id":"143","workName":"task-143"} 正常执行！
当前任务：146 | 消息为: {"id":"146","workName":"task-146"} 正常执行！
当前任务：150 | 消息为: {"id":"150","workName":"task-150"} 正常执行！
当前任务：155 | 消息为: {"id":"155","workName":"task-155"} 正常执行！
当前任务：145 | 消息为: {"id":"145","workName":"task-145"} 正常执行！
当前任务：141 | 消息为: {"id":"141","workName":"task-141"} 正常执行！
当前任务：156 | 消息为: {"id":"156","workName":"task-156"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：144 | 消息为: {"id":"144","workName":"task-144"} 正常执行！
当前任务：158 | 消息为: {"id":"158","workName":"task-158"} 正常执行！
重新放入队列前的队列大小为: 3
重新放入队列后的队列大小为: 3
重新放入队列前的队列大小为: 10
182 被丢弃! 此时消息为: {"id":"182","workName":"task-182"}
190 被丢弃! 此时消息为: {"id":"190","workName":"task-190"}
当前任务：168 | 消息为: {"id":"168","workName":"task-168"} 正常执行！
当前任务：174 | 消息为: {"id":"174","workName":"task-174"} 正常执行！
当前任务：163 | 消息为: {"id":"163","workName":"task-163"} 正常执行！
当前任务：160 | 消息为: {"id":"160","workName":"task-160"} 正常执行！
当前任务：161 | 消息为: {"id":"161","workName":"task-161"} 正常执行！
当前任务：164 | 消息为: {"id":"164","workName":"task-164"} 正常执行！
当前任务：171 | 消息为: {"id":"171","workName":"task-171"} 正常执行！
当前任务：177 | 消息为: {"id":"177","workName":"task-177"} 正常执行！
当前任务：165 | 消息为: {"id":"165","workName":"task-165"} 正常执行！
当前任务：179 | 消息为: {"id":"179","workName":"task-179"} 正常执行！
当前任务：175 | 消息为: {"id":"175","workName":"task-175"} 正常执行！
当前任务：178 | 消息为: {"id":"178","workName":"task-178"} 正常执行！
当前任务：172 | 消息为: {"id":"172","workName":"task-172"} 正常执行！
当前任务：173 | 消息为: {"id":"173","workName":"task-173"} 正常执行！
当前任务：170 | 消息为: {"id":"170","workName":"task-170"} 正常执行！
当前任务：167 | 消息为: {"id":"167","workName":"task-167"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：169 | 消息为: {"id":"169","workName":"task-169"} 正常执行！
当前任务：162 | 消息为: {"id":"162","workName":"task-162"} 正常执行！
当前任务：176 | 消息为: {"id":"176","workName":"task-176"} 正常执行！
当前任务：166 | 消息为: {"id":"166","workName":"task-166"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 5
重新放入队列前的队列大小为: 10
204 被丢弃! 此时消息为: {"id":"204","workName":"task-204"}
210 被丢弃! 此时消息为: {"id":"210","workName":"task-210"}
当前任务：181 | 消息为: {"id":"181","workName":"task-181"} 正常执行！
当前任务：198 | 消息为: {"id":"198","workName":"task-198"} 正常执行！
当前任务：193 | 消息为: {"id":"193","workName":"task-193"} 正常执行！
当前任务：195 | 消息为: {"id":"195","workName":"task-195"} 正常执行！
当前任务：192 | 消息为: {"id":"192","workName":"task-192"} 正常执行！
当前任务：186 | 消息为: {"id":"186","workName":"task-186"} 正常执行！
当前任务：196 | 消息为: {"id":"196","workName":"task-196"} 正常执行！
当前任务：187 | 消息为: {"id":"187","workName":"task-187"} 正常执行！
当前任务：194 | 消息为: {"id":"194","workName":"task-194"} 正常执行！
当前任务：188 | 消息为: {"id":"188","workName":"task-188"} 正常执行！
当前任务：199 | 消息为: {"id":"199","workName":"task-199"} 正常执行！
当前任务：183 | 消息为: {"id":"183","workName":"task-183"} 正常执行！
当前任务：185 | 消息为: {"id":"185","workName":"task-185"} 正常执行！
当前任务：190 | 消息为: {"id":"190","workName":"task-190"} 正常执行！
当前任务：182 | 消息为: {"id":"182","workName":"task-182"} 正常执行！
当前任务：184 | 消息为: {"id":"184","workName":"task-184"} 正常执行！
当前任务：191 | 消息为: {"id":"191","workName":"task-191"} 正常执行！
当前任务：197 | 消息为: {"id":"197","workName":"task-197"} 正常执行！
当前任务：180 | 消息为: {"id":"180","workName":"task-180"} 正常执行！
当前任务：189 | 消息为: {"id":"189","workName":"task-189"} 正常执行！
重新放入队列后的队列大小为: 10
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 8
重新放入队列后的队列大小为: 9
重新放入队列前的队列大小为: 10
221 被丢弃! 此时消息为: {"id":"221","workName":"task-221"}
228 被丢弃! 此时消息为: {"id":"228","workName":"task-228"}
230 被丢弃! 此时消息为: {"id":"230","workName":"task-230"}
当前任务：202 | 消息为: {"id":"202","workName":"task-202"} 正常执行！
当前任务：201 | 消息为: {"id":"201","workName":"task-201"} 正常执行！
当前任务：209 | 消息为: {"id":"209","workName":"task-209"} 正常执行！
当前任务：204 | 消息为: {"id":"204","workName":"task-204"} 正常执行！
当前任务：203 | 消息为: {"id":"203","workName":"task-203"} 正常执行！
当前任务：217 | 消息为: {"id":"217","workName":"task-217"} 正常执行！
当前任务：214 | 消息为: {"id":"214","workName":"task-214"} 正常执行！
当前任务：218 | 消息为: {"id":"218","workName":"task-218"} 正常执行！
当前任务：200 | 消息为: {"id":"200","workName":"task-200"} 正常执行！
当前任务：207 | 消息为: {"id":"207","workName":"task-207"} 正常执行！
当前任务：211 | 消息为: {"id":"211","workName":"task-211"} 正常执行！
当前任务：210 | 消息为: {"id":"210","workName":"task-210"} 正常执行！
当前任务：215 | 消息为: {"id":"215","workName":"task-215"} 正常执行！
当前任务：212 | 消息为: {"id":"212","workName":"task-212"} 正常执行！
当前任务：213 | 消息为: {"id":"213","workName":"task-213"} 正常执行！
当前任务：206 | 消息为: {"id":"206","workName":"task-206"} 正常执行！
当前任务：216 | 消息为: {"id":"216","workName":"task-216"} 正常执行！
当前任务：205 | 消息为: {"id":"205","workName":"task-205"} 正常执行！
当前任务：208 | 消息为: {"id":"208","workName":"task-208"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：219 | 消息为: {"id":"219","workName":"task-219"} 正常执行！
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 10
243 被丢弃! 此时消息为: {"id":"243","workName":"task-243"}
250 被丢弃! 此时消息为: {"id":"250","workName":"task-250"}
当前任务：228 | 消息为: {"id":"228","workName":"task-228"} 正常执行！
当前任务：238 | 消息为: {"id":"238","workName":"task-238"} 正常执行！
当前任务：234 | 消息为: {"id":"234","workName":"task-234"} 正常执行！
当前任务：229 | 消息为: {"id":"229","workName":"task-229"} 正常执行！
当前任务：230 | 消息为: {"id":"230","workName":"task-230"} 正常执行！
当前任务：235 | 消息为: {"id":"235","workName":"task-235"} 正常执行！
当前任务：221 | 消息为: {"id":"221","workName":"task-221"} 正常执行！
当前任务：227 | 消息为: {"id":"227","workName":"task-227"} 正常执行！
当前任务：225 | 消息为: {"id":"225","workName":"task-225"} 正常执行！
当前任务：231 | 消息为: {"id":"231","workName":"task-231"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：237 | 消息为: {"id":"237","workName":"task-237"} 正常执行！
当前任务：236 | 消息为: {"id":"236","workName":"task-236"} 正常执行！
当前任务：233 | 消息为: {"id":"233","workName":"task-233"} 正常执行！
当前任务：222 | 消息为: {"id":"222","workName":"task-222"} 正常执行！
当前任务：223 | 消息为: {"id":"223","workName":"task-223"} 正常执行！
当前任务：220 | 消息为: {"id":"220","workName":"task-220"} 正常执行！
当前任务：232 | 消息为: {"id":"232","workName":"task-232"} 正常执行！
当前任务：226 | 消息为: {"id":"226","workName":"task-226"} 正常执行！
当前任务：239 | 消息为: {"id":"239","workName":"task-239"} 正常执行！
当前任务：224 | 消息为: {"id":"224","workName":"task-224"} 正常执行！
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 1
重新放入队列前的队列大小为: 10
260 被丢弃! 此时消息为: {"id":"260","workName":"task-260"}
270 被丢弃! 此时消息为: {"id":"270","workName":"task-270"}
当前任务：254 | 消息为: {"id":"254","workName":"task-254"} 正常执行！
当前任务：243 | 消息为: {"id":"243","workName":"task-243"} 正常执行！
当前任务：251 | 消息为: {"id":"251","workName":"task-251"} 正常执行！
当前任务：245 | 消息为: {"id":"245","workName":"task-245"} 正常执行！
当前任务：255 | 消息为: {"id":"255","workName":"task-255"} 正常执行！
当前任务：244 | 消息为: {"id":"244","workName":"task-244"} 正常执行！
当前任务：258 | 消息为: {"id":"258","workName":"task-258"} 正常执行！
当前任务：257 | 消息为: {"id":"257","workName":"task-257"} 正常执行！
当前任务：253 | 消息为: {"id":"253","workName":"task-253"} 正常执行！
当前任务：249 | 消息为: {"id":"249","workName":"task-249"} 正常执行！
当前任务：248 | 消息为: {"id":"248","workName":"task-248"} 正常执行！
当前任务：242 | 消息为: {"id":"242","workName":"task-242"} 正常执行！
当前任务：241 | 消息为: {"id":"241","workName":"task-241"} 正常执行！
当前任务：259 | 消息为: {"id":"259","workName":"task-259"} 正常执行！
当前任务：240 | 消息为: {"id":"240","workName":"task-240"} 正常执行！
当前任务：247 | 消息为: {"id":"247","workName":"task-247"} 正常执行！
当前任务：256 | 消息为: {"id":"256","workName":"task-256"} 正常执行！
重新放入队列后的队列大小为: 10
当前任务：246 | 消息为: {"id":"246","workName":"task-246"} 正常执行！
当前任务：250 | 消息为: {"id":"250","workName":"task-250"} 正常执行！
当前任务：252 | 消息为: {"id":"252","workName":"task-252"} 正常执行！
重新放入队列前的队列大小为: 2
重新放入队列后的队列大小为: 3
重新放入队列前的队列大小为: 10
282 被丢弃! 此时消息为: {"id":"282","workName":"task-282"}
290 被丢弃! 此时消息为: {"id":"290","workName":"task-290"}
当前任务：278 | 消息为: {"id":"278","workName":"task-278"} 正常执行！
当前任务：279 | 消息为: {"id":"279","workName":"task-279"} 正常执行！
当前任务：277 | 消息为: {"id":"277","workName":"task-277"} 正常执行！
当前任务：273 | 消息为: {"id":"273","workName":"task-273"} 正常执行！
重新放入队列后的队列大小为: 8
当前任务：276 | 消息为: {"id":"276","workName":"task-276"} 正常执行！
当前任务：266 | 消息为: {"id":"266","workName":"task-266"} 正常执行！
当前任务：271 | 消息为: {"id":"271","workName":"task-271"} 正常执行！
当前任务：272 | 消息为: {"id":"272","workName":"task-272"} 正常执行！
当前任务：270 | 消息为: {"id":"270","workName":"task-270"} 正常执行！
当前任务：262 | 消息为: {"id":"262","workName":"task-262"} 正常执行！
当前任务：264 | 消息为: {"id":"264","workName":"task-264"} 正常执行！
重新放入队列前的队列大小为: 7
当前任务：263 | 消息为: {"id":"263","workName":"task-263"} 正常执行！
当前任务：268 | 消息为: {"id":"268","workName":"task-268"} 正常执行！
当前任务：267 | 消息为: {"id":"267","workName":"task-267"} 正常执行！
当前任务：261 | 消息为: {"id":"261","workName":"task-261"} 正常执行！
当前任务：260 | 消息为: {"id":"260","workName":"task-260"} 正常执行！
当前任务：274 | 消息为: {"id":"274","workName":"task-274"} 正常执行！
当前任务：269 | 消息为: {"id":"269","workName":"task-269"} 正常执行！
当前任务：275 | 消息为: {"id":"275","workName":"task-275"} 正常执行！
当前任务：265 | 消息为: {"id":"265","workName":"task-265"} 正常执行！
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 7
重新放入队列前的队列大小为: 10
294 被丢弃! 此时消息为: {"id":"294","workName":"task-294"}
306 被丢弃! 此时消息为: {"id":"306","workName":"task-306"}
310 被丢弃! 此时消息为: {"id":"310","workName":"task-310"}
当前任务：296 | 消息为: {"id":"296","workName":"task-296"} 正常执行！
当前任务：298 | 消息为: {"id":"298","workName":"task-298"} 正常执行！
当前任务：283 | 消息为: {"id":"283","workName":"task-283"} 正常执行！
重新放入队列后的队列大小为: 10
当前任务：288 | 消息为: {"id":"288","workName":"task-288"} 正常执行！
当前任务：284 | 消息为: {"id":"284","workName":"task-284"} 正常执行！
当前任务：280 | 消息为: {"id":"280","workName":"task-280"} 正常执行！
当前任务：290 | 消息为: {"id":"290","workName":"task-290"} 正常执行！
当前任务：297 | 消息为: {"id":"297","workName":"task-297"} 正常执行！
当前任务：282 | 消息为: {"id":"282","workName":"task-282"} 正常执行！
当前任务：295 | 消息为: {"id":"295","workName":"task-295"} 正常执行！
当前任务：289 | 消息为: {"id":"289","workName":"task-289"} 正常执行！
当前任务：294 | 消息为: {"id":"294","workName":"task-294"} 正常执行！
当前任务：281 | 消息为: {"id":"281","workName":"task-281"} 正常执行！
当前任务：293 | 消息为: {"id":"293","workName":"task-293"} 正常执行！
当前任务：285 | 消息为: {"id":"285","workName":"task-285"} 正常执行！
当前任务：299 | 消息为: {"id":"299","workName":"task-299"} 正常执行！
当前任务：286 | 消息为: {"id":"286","workName":"task-286"} 正常执行！
当前任务：292 | 消息为: {"id":"292","workName":"task-292"} 正常执行！
当前任务：287 | 消息为: {"id":"287","workName":"task-287"} 正常执行！
当前任务：291 | 消息为: {"id":"291","workName":"task-291"} 正常执行！
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 1
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 7
重新放入队列前的队列大小为: 10
313 被丢弃! 此时消息为: {"id":"313","workName":"task-313"}
326 被丢弃! 此时消息为: {"id":"326","workName":"task-326"}
330 被丢弃! 此时消息为: {"id":"330","workName":"task-330"}
当前任务：312 | 消息为: {"id":"312","workName":"task-312"} 正常执行！
当前任务：315 | 消息为: {"id":"315","workName":"task-315"} 正常执行！
当前任务：314 | 消息为: {"id":"314","workName":"task-314"} 正常执行！
当前任务：309 | 消息为: {"id":"309","workName":"task-309"} 正常执行！
当前任务：302 | 消息为: {"id":"302","workName":"task-302"} 正常执行！
当前任务：313 | 消息为: {"id":"313","workName":"task-313"} 正常执行！
当前任务：305 | 消息为: {"id":"305","workName":"task-305"} 正常执行！
当前任务：306 | 消息为: {"id":"306","workName":"task-306"} 正常执行！
当前任务：311 | 消息为: {"id":"311","workName":"task-311"} 正常执行！
当前任务：318 | 消息为: {"id":"318","workName":"task-318"} 正常执行！
当前任务：310 | 消息为: {"id":"310","workName":"task-310"} 正常执行！
当前任务：304 | 消息为: {"id":"304","workName":"task-304"} 正常执行！
当前任务：308 | 消息为: {"id":"308","workName":"task-308"} 正常执行！
当前任务：319 | 消息为: {"id":"319","workName":"task-319"} 正常执行！
当前任务：300 | 消息为: {"id":"300","workName":"task-300"} 正常执行！
当前任务：317 | 消息为: {"id":"317","workName":"task-317"} 正常执行！
当前任务：316 | 消息为: {"id":"316","workName":"task-316"} 正常执行！
当前任务：307 | 消息为: {"id":"307","workName":"task-307"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：303 | 消息为: {"id":"303","workName":"task-303"} 正常执行！
当前任务：301 | 消息为: {"id":"301","workName":"task-301"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 10
343 被丢弃! 此时消息为: {"id":"343","workName":"task-343"}
350 被丢弃! 此时消息为: {"id":"350","workName":"task-350"}
当前任务：336 | 消息为: {"id":"336","workName":"task-336"} 正常执行！
当前任务：322 | 消息为: {"id":"322","workName":"task-322"} 正常执行！
当前任务：338 | 消息为: {"id":"338","workName":"task-338"} 正常执行！
当前任务：325 | 消息为: {"id":"325","workName":"task-325"} 正常执行！
当前任务：337 | 消息为: {"id":"337","workName":"task-337"} 正常执行！
当前任务：326 | 消息为: {"id":"326","workName":"task-326"} 正常执行！
当前任务：323 | 消息为: {"id":"323","workName":"task-323"} 正常执行！
当前任务：333 | 消息为: {"id":"333","workName":"task-333"} 正常执行！
当前任务：335 | 消息为: {"id":"335","workName":"task-335"} 正常执行！
当前任务：331 | 消息为: {"id":"331","workName":"task-331"} 正常执行！
当前任务：330 | 消息为: {"id":"330","workName":"task-330"} 正常执行！
当前任务：332 | 消息为: {"id":"332","workName":"task-332"} 正常执行！
当前任务：327 | 消息为: {"id":"327","workName":"task-327"} 正常执行！
当前任务：320 | 消息为: {"id":"320","workName":"task-320"} 正常执行！
当前任务：324 | 消息为: {"id":"324","workName":"task-324"} 正常执行！
重新放入队列后的队列大小为: 8
当前任务：321 | 消息为: {"id":"321","workName":"task-321"} 正常执行！
当前任务：339 | 消息为: {"id":"339","workName":"task-339"} 正常执行！
当前任务：334 | 消息为: {"id":"334","workName":"task-334"} 正常执行！
当前任务：329 | 消息为: {"id":"329","workName":"task-329"} 正常执行！
重新放入队列前的队列大小为: 4
当前任务：328 | 消息为: {"id":"328","workName":"task-328"} 正常执行！
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 10
362 被丢弃! 此时消息为: {"id":"362","workName":"task-362"}
370 被丢弃! 此时消息为: {"id":"370","workName":"task-370"}
当前任务：343 | 消息为: {"id":"343","workName":"task-343"} 正常执行！
当前任务：348 | 消息为: {"id":"348","workName":"task-348"} 正常执行！
当前任务：350 | 消息为: {"id":"350","workName":"task-350"} 正常执行！
当前任务：352 | 消息为: {"id":"352","workName":"task-352"} 正常执行！
当前任务：347 | 消息为: {"id":"347","workName":"task-347"} 正常执行！
当前任务：355 | 消息为: {"id":"355","workName":"task-355"} 正常执行！
当前任务：349 | 消息为: {"id":"349","workName":"task-349"} 正常执行！
当前任务：342 | 消息为: {"id":"342","workName":"task-342"} 正常执行！
当前任务：357 | 消息为: {"id":"357","workName":"task-357"} 正常执行！
当前任务：358 | 消息为: {"id":"358","workName":"task-358"} 正常执行！
当前任务：345 | 消息为: {"id":"345","workName":"task-345"} 正常执行！
当前任务：341 | 消息为: {"id":"341","workName":"task-341"} 正常执行！
当前任务：346 | 消息为: {"id":"346","workName":"task-346"} 正常执行！
当前任务：359 | 消息为: {"id":"359","workName":"task-359"} 正常执行！
当前任务：340 | 消息为: {"id":"340","workName":"task-340"} 正常执行！
当前任务：353 | 消息为: {"id":"353","workName":"task-353"} 正常执行！
当前任务：354 | 消息为: {"id":"354","workName":"task-354"} 正常执行！
当前任务：344 | 消息为: {"id":"344","workName":"task-344"} 正常执行！
当前任务：356 | 消息为: {"id":"356","workName":"task-356"} 正常执行！
当前任务：351 | 消息为: {"id":"351","workName":"task-351"} 正常执行！
重新放入队列后的队列大小为: 9
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 9
重新放入队列后的队列大小为: 10
重新放入队列前的队列大小为: 10
382 被丢弃! 此时消息为: {"id":"382","workName":"task-382"}
389 被丢弃! 此时消息为: {"id":"389","workName":"task-389"}
390 被丢弃! 此时消息为: {"id":"390","workName":"task-390"}
当前任务：364 | 消息为: {"id":"364","workName":"task-364"} 正常执行！
当前任务：374 | 消息为: {"id":"374","workName":"task-374"} 正常执行！
当前任务：370 | 消息为: {"id":"370","workName":"task-370"} 正常执行！
当前任务：360 | 消息为: {"id":"360","workName":"task-360"} 正常执行！
当前任务：373 | 消息为: {"id":"373","workName":"task-373"} 正常执行！
当前任务：375 | 消息为: {"id":"375","workName":"task-375"} 正常执行！
当前任务：363 | 消息为: {"id":"363","workName":"task-363"} 正常执行！
当前任务：372 | 消息为: {"id":"372","workName":"task-372"} 正常执行！
当前任务：366 | 消息为: {"id":"366","workName":"task-366"} 正常执行！
当前任务：361 | 消息为: {"id":"361","workName":"task-361"} 正常执行！
当前任务：376 | 消息为: {"id":"376","workName":"task-376"} 正常执行！
当前任务：378 | 消息为: {"id":"378","workName":"task-378"} 正常执行！
当前任务：377 | 消息为: {"id":"377","workName":"task-377"} 正常执行！
当前任务：365 | 消息为: {"id":"365","workName":"task-365"} 正常执行！
当前任务：379 | 消息为: {"id":"379","workName":"task-379"} 正常执行！
当前任务：362 | 消息为: {"id":"362","workName":"task-362"} 正常执行！
当前任务：368 | 消息为: {"id":"368","workName":"task-368"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：367 | 消息为: {"id":"367","workName":"task-367"} 正常执行！
当前任务：369 | 消息为: {"id":"369","workName":"task-369"} 正常执行！
当前任务：371 | 消息为: {"id":"371","workName":"task-371"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 10
402 被丢弃! 此时消息为: {"id":"402","workName":"task-402"}
410 被丢弃! 此时消息为: {"id":"410","workName":"task-410"}
当前任务：398 | 消息为: {"id":"398","workName":"task-398"} 正常执行！
当前任务：390 | 消息为: {"id":"390","workName":"task-390"} 正常执行！
当前任务：388 | 消息为: {"id":"388","workName":"task-388"} 正常执行！
当前任务：385 | 消息为: {"id":"385","workName":"task-385"} 正常执行！
当前任务：382 | 消息为: {"id":"382","workName":"task-382"} 正常执行！
当前任务：396 | 消息为: {"id":"396","workName":"task-396"} 正常执行！
当前任务：392 | 消息为: {"id":"392","workName":"task-392"} 正常执行！
当前任务：397 | 消息为: {"id":"397","workName":"task-397"} 正常执行！
当前任务：380 | 消息为: {"id":"380","workName":"task-380"} 正常执行！
当前任务：399 | 消息为: {"id":"399","workName":"task-399"} 正常执行！
当前任务：387 | 消息为: {"id":"387","workName":"task-387"} 正常执行！
当前任务：381 | 消息为: {"id":"381","workName":"task-381"} 正常执行！
当前任务：386 | 消息为: {"id":"386","workName":"task-386"} 正常执行！
当前任务：393 | 消息为: {"id":"393","workName":"task-393"} 正常执行！
当前任务：394 | 消息为: {"id":"394","workName":"task-394"} 正常执行！
当前任务：395 | 消息为: {"id":"395","workName":"task-395"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：389 | 消息为: {"id":"389","workName":"task-389"} 正常执行！
当前任务：384 | 消息为: {"id":"384","workName":"task-384"} 正常执行！
当前任务：383 | 消息为: {"id":"383","workName":"task-383"} 正常执行！
当前任务：391 | 消息为: {"id":"391","workName":"task-391"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10
421 被丢弃! 此时消息为: {"id":"421","workName":"task-421"}
430 被丢弃! 此时消息为: {"id":"430","workName":"task-430"}
当前任务：417 | 消息为: {"id":"417","workName":"task-417"} 正常执行！
当前任务：412 | 消息为: {"id":"412","workName":"task-412"} 正常执行！
当前任务：403 | 消息为: {"id":"403","workName":"task-403"} 正常执行！
当前任务：419 | 消息为: {"id":"419","workName":"task-419"} 正常执行！
当前任务：402 | 消息为: {"id":"402","workName":"task-402"} 正常执行！
当前任务：410 | 消息为: {"id":"410","workName":"task-410"} 正常执行！
当前任务：415 | 消息为: {"id":"415","workName":"task-415"} 正常执行！
当前任务：405 | 消息为: {"id":"405","workName":"task-405"} 正常执行！
当前任务：414 | 消息为: {"id":"414","workName":"task-414"} 正常执行！
当前任务：401 | 消息为: {"id":"401","workName":"task-401"} 正常执行！
当前任务：411 | 消息为: {"id":"411","workName":"task-411"} 正常执行！
当前任务：413 | 消息为: {"id":"413","workName":"task-413"} 正常执行！
当前任务：418 | 消息为: {"id":"418","workName":"task-418"} 正常执行！
当前任务：409 | 消息为: {"id":"409","workName":"task-409"} 正常执行！
当前任务：400 | 消息为: {"id":"400","workName":"task-400"} 正常执行！
当前任务：406 | 消息为: {"id":"406","workName":"task-406"} 正常执行！
当前任务：408 | 消息为: {"id":"408","workName":"task-408"} 正常执行！
当前任务：404 | 消息为: {"id":"404","workName":"task-404"} 正常执行！
当前任务：407 | 消息为: {"id":"407","workName":"task-407"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：416 | 消息为: {"id":"416","workName":"task-416"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 9
重新放入队列后的队列大小为: 10
重新放入队列前的队列大小为: 10
441 被丢弃! 此时消息为: {"id":"441","workName":"task-441"}
449 被丢弃! 此时消息为: {"id":"449","workName":"task-449"}
450 被丢弃! 此时消息为: {"id":"450","workName":"task-450"}
453 被丢弃! 此时消息为: {"id":"453","workName":"task-453"}
464 被丢弃! 此时消息为: {"id":"464","workName":"task-464"}
469 被丢弃! 此时消息为: {"id":"469","workName":"task-469"}
470 被丢弃! 此时消息为: {"id":"470","workName":"task-470"}
当前任务：435 | 消息为: {"id":"435","workName":"task-435"} 正常执行！
当前任务：430 | 消息为: {"id":"430","workName":"task-430"} 正常执行！
当前任务：433 | 消息为: {"id":"433","workName":"task-433"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：424 | 消息为: {"id":"424","workName":"task-424"} 正常执行！
当前任务：427 | 消息为: {"id":"427","workName":"task-427"} 正常执行！
当前任务：436 | 消息为: {"id":"436","workName":"task-436"} 正常执行！
当前任务：422 | 消息为: {"id":"422","workName":"task-422"} 正常执行！
当前任务：425 | 消息为: {"id":"425","workName":"task-425"} 正常执行！
当前任务：429 | 消息为: {"id":"429","workName":"task-429"} 正常执行！
重新放入队列前的队列大小为: 7
当前任务：420 | 消息为: {"id":"420","workName":"task-420"} 正常执行！
当前任务：431 | 消息为: {"id":"431","workName":"task-431"} 正常执行！
当前任务：423 | 消息为: {"id":"423","workName":"task-423"} 正常执行！
当前任务：434 | 消息为: {"id":"434","workName":"task-434"} 正常执行！
当前任务：432 | 消息为: {"id":"432","workName":"task-432"} 正常执行！
当前任务：426 | 消息为: {"id":"426","workName":"task-426"} 正常执行！
当前任务：421 | 消息为: {"id":"421","workName":"task-421"} 正常执行！
当前任务：437 | 消息为: {"id":"437","workName":"task-437"} 正常执行！
当前任务：428 | 消息为: {"id":"428","workName":"task-428"} 正常执行！
当前任务：438 | 消息为: {"id":"438","workName":"task-438"} 正常执行！
当前任务：439 | 消息为: {"id":"439","workName":"task-439"} 正常执行！
重新放入队列后的队列大小为: 5
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 9
重新放入队列后的队列大小为: 10
重新放入队列前的队列大小为: 10
当前任务：452 | 消息为: {"id":"452","workName":"task-452"} 正常执行！
当前任务：459 | 消息为: {"id":"459","workName":"task-459"} 正常执行！
当前任务：443 | 消息为: {"id":"443","workName":"task-443"} 正常执行！
当前任务：440 | 消息为: {"id":"440","workName":"task-440"} 正常执行！
当前任务：441 | 消息为: {"id":"441","workName":"task-441"} 正常执行！
当前任务：446 | 消息为: {"id":"446","workName":"task-446"} 正常执行！
当前任务：455 | 消息为: {"id":"455","workName":"task-455"} 正常执行！
当前任务：450 | 消息为: {"id":"450","workName":"task-450"} 正常执行！
当前任务：447 | 消息为: {"id":"447","workName":"task-447"} 正常执行！
当前任务：442 | 消息为: {"id":"442","workName":"task-442"} 正常执行！
当前任务：449 | 消息为: {"id":"449","workName":"task-449"} 正常执行！
当前任务：445 | 消息为: {"id":"445","workName":"task-445"} 正常执行！
当前任务：456 | 消息为: {"id":"456","workName":"task-456"} 正常执行！
当前任务：457 | 消息为: {"id":"457","workName":"task-457"} 正常执行！
当前任务：453 | 消息为: {"id":"453","workName":"task-453"} 正常执行！
当前任务：458 | 消息为: {"id":"458","workName":"task-458"} 正常执行！
当前任务：448 | 消息为: {"id":"448","workName":"task-448"} 正常执行！
当前任务：444 | 消息为: {"id":"444","workName":"task-444"} 正常执行！
当前任务：451 | 消息为: {"id":"451","workName":"task-451"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：454 | 消息为: {"id":"454","workName":"task-454"} 正常执行！
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 8
重新放入队列前的队列大小为: 10
481 被丢弃! 此时消息为: {"id":"481","workName":"task-481"}
487 被丢弃! 此时消息为: {"id":"487","workName":"task-487"}
490 被丢弃! 此时消息为: {"id":"490","workName":"task-490"}
当前任务：479 | 消息为: {"id":"479","workName":"task-479"} 正常执行！
当前任务：469 | 消息为: {"id":"469","workName":"task-469"} 正常执行！
当前任务：461 | 消息为: {"id":"461","workName":"task-461"} 正常执行！
当前任务：465 | 消息为: {"id":"465","workName":"task-465"} 正常执行！
当前任务：472 | 消息为: {"id":"472","workName":"task-472"} 正常执行！
当前任务：466 | 消息为: {"id":"466","workName":"task-466"} 正常执行！
当前任务：467 | 消息为: {"id":"467","workName":"task-467"} 正常执行！
当前任务：475 | 消息为: {"id":"475","workName":"task-475"} 正常执行！
当前任务：460 | 消息为: {"id":"460","workName":"task-460"} 正常执行！
当前任务：468 | 消息为: {"id":"468","workName":"task-468"} 正常执行！
当前任务：464 | 消息为: {"id":"464","workName":"task-464"} 正常执行！
当前任务：477 | 消息为: {"id":"477","workName":"task-477"} 正常执行！
当前任务：470 | 消息为: {"id":"470","workName":"task-470"} 正常执行！
当前任务：474 | 消息为: {"id":"474","workName":"task-474"} 正常执行！
当前任务：473 | 消息为: {"id":"473","workName":"task-473"} 正常执行！
当前任务：471 | 消息为: {"id":"471","workName":"task-471"} 正常执行！
当前任务：476 | 消息为: {"id":"476","workName":"task-476"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：478 | 消息为: {"id":"478","workName":"task-478"} 正常执行！
当前任务：463 | 消息为: {"id":"463","workName":"task-463"} 正常执行！
当前任务：462 | 消息为: {"id":"462","workName":"task-462"} 正常执行！
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 8
重新放入队列后的队列大小为: 9
重新放入队列前的队列大小为: 10
501 被丢弃! 此时消息为: {"id":"501","workName":"task-501"}
508 被丢弃! 此时消息为: {"id":"508","workName":"task-508"}
510 被丢弃! 此时消息为: {"id":"510","workName":"task-510"}
当前任务：496 | 消息为: {"id":"496","workName":"task-496"} 正常执行！
当前任务：481 | 消息为: {"id":"481","workName":"task-481"} 正常执行！
当前任务：493 | 消息为: {"id":"493","workName":"task-493"} 正常执行！
当前任务：487 | 消息为: {"id":"487","workName":"task-487"} 正常执行！
当前任务：480 | 消息为: {"id":"480","workName":"task-480"} 正常执行！
当前任务：495 | 消息为: {"id":"495","workName":"task-495"} 正常执行！
当前任务：494 | 消息为: {"id":"494","workName":"task-494"} 正常执行！
当前任务：489 | 消息为: {"id":"489","workName":"task-489"} 正常执行！
当前任务：483 | 消息为: {"id":"483","workName":"task-483"} 正常执行！
当前任务：482 | 消息为: {"id":"482","workName":"task-482"} 正常执行！
当前任务：490 | 消息为: {"id":"490","workName":"task-490"} 正常执行！
当前任务：499 | 消息为: {"id":"499","workName":"task-499"} 正常执行！
当前任务：486 | 消息为: {"id":"486","workName":"task-486"} 正常执行！
当前任务：498 | 消息为: {"id":"498","workName":"task-498"} 正常执行！
当前任务：484 | 消息为: {"id":"484","workName":"task-484"} 正常执行！
当前任务：485 | 消息为: {"id":"485","workName":"task-485"} 正常执行！
当前任务：491 | 消息为: {"id":"491","workName":"task-491"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：497 | 消息为: {"id":"497","workName":"task-497"} 正常执行！
当前任务：488 | 消息为: {"id":"488","workName":"task-488"} 正常执行！
当前任务：492 | 消息为: {"id":"492","workName":"task-492"} 正常执行！
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 8
重新放入队列前的队列大小为: 10
521 被丢弃! 此时消息为: {"id":"521","workName":"task-521"}
527 被丢弃! 此时消息为: {"id":"527","workName":"task-527"}
530 被丢弃! 此时消息为: {"id":"530","workName":"task-530"}
当前任务：506 | 消息为: {"id":"506","workName":"task-506"} 正常执行！
当前任务：513 | 消息为: {"id":"513","workName":"task-513"} 正常执行！
当前任务：519 | 消息为: {"id":"519","workName":"task-519"} 正常执行！
当前任务：511 | 消息为: {"id":"511","workName":"task-511"} 正常执行！
当前任务：500 | 消息为: {"id":"500","workName":"task-500"} 正常执行！
当前任务：508 | 消息为: {"id":"508","workName":"task-508"} 正常执行！
当前任务：518 | 消息为: {"id":"518","workName":"task-518"} 正常执行！
当前任务：507 | 消息为: {"id":"507","workName":"task-507"} 正常执行！
当前任务：509 | 消息为: {"id":"509","workName":"task-509"} 正常执行！
当前任务：515 | 消息为: {"id":"515","workName":"task-515"} 正常执行！
当前任务：514 | 消息为: {"id":"514","workName":"task-514"} 正常执行！
当前任务：504 | 消息为: {"id":"504","workName":"task-504"} 正常执行！
当前任务：516 | 消息为: {"id":"516","workName":"task-516"} 正常执行！
重新放入队列后的队列大小为: 10
当前任务：505 | 消息为: {"id":"505","workName":"task-505"} 正常执行！
当前任务：501 | 消息为: {"id":"501","workName":"task-501"} 正常执行！
当前任务：512 | 消息为: {"id":"512","workName":"task-512"} 正常执行！
重新放入队列前的队列大小为: 6
当前任务：502 | 消息为: {"id":"502","workName":"task-502"} 正常执行！
当前任务：517 | 消息为: {"id":"517","workName":"task-517"} 正常执行！
当前任务：510 | 消息为: {"id":"510","workName":"task-510"} 正常执行！
当前任务：503 | 消息为: {"id":"503","workName":"task-503"} 正常执行！
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 10
541 被丢弃! 此时消息为: {"id":"541","workName":"task-541"}
550 被丢弃! 此时消息为: {"id":"550","workName":"task-550"}
当前任务：521 | 消息为: {"id":"521","workName":"task-521"} 正常执行！
当前任务：522 | 消息为: {"id":"522","workName":"task-522"} 正常执行！
当前任务：531 | 消息为: {"id":"531","workName":"task-531"} 正常执行！
当前任务：520 | 消息为: {"id":"520","workName":"task-520"} 正常执行！
当前任务：528 | 消息为: {"id":"528","workName":"task-528"} 正常执行！
当前任务：539 | 消息为: {"id":"539","workName":"task-539"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：537 | 消息为: {"id":"537","workName":"task-537"} 正常执行！
当前任务：532 | 消息为: {"id":"532","workName":"task-532"} 正常执行！
当前任务：530 | 消息为: {"id":"530","workName":"task-530"} 正常执行！
当前任务：523 | 消息为: {"id":"523","workName":"task-523"} 正常执行！
当前任务：533 | 消息为: {"id":"533","workName":"task-533"} 正常执行！
当前任务：525 | 消息为: {"id":"525","workName":"task-525"} 正常执行！
当前任务：538 | 消息为: {"id":"538","workName":"task-538"} 正常执行！
重新放入队列前的队列大小为: 8
当前任务：536 | 消息为: {"id":"536","workName":"task-536"} 正常执行！
当前任务：535 | 消息为: {"id":"535","workName":"task-535"} 正常执行！
当前任务：529 | 消息为: {"id":"529","workName":"task-529"} 正常执行！
当前任务：526 | 消息为: {"id":"526","workName":"task-526"} 正常执行！
当前任务：534 | 消息为: {"id":"534","workName":"task-534"} 正常执行！
当前任务：527 | 消息为: {"id":"527","workName":"task-527"} 正常执行！
当前任务：524 | 消息为: {"id":"524","workName":"task-524"} 正常执行！
重新放入队列后的队列大小为: 4
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 8
重新放入队列前的队列大小为: 10
556 被丢弃! 此时消息为: {"id":"556","workName":"task-556"}
567 被丢弃! 此时消息为: {"id":"567","workName":"task-567"}
570 被丢弃! 此时消息为: {"id":"570","workName":"task-570"}
当前任务：550 | 消息为: {"id":"550","workName":"task-550"} 正常执行！
当前任务：556 | 消息为: {"id":"556","workName":"task-556"} 正常执行！
当前任务：559 | 消息为: {"id":"559","workName":"task-559"} 正常执行！
当前任务：554 | 消息为: {"id":"554","workName":"task-554"} 正常执行！
当前任务：545 | 消息为: {"id":"545","workName":"task-545"} 正常执行！
当前任务：557 | 消息为: {"id":"557","workName":"task-557"} 正常执行！
当前任务：542 | 消息为: {"id":"542","workName":"task-542"} 正常执行！
当前任务：551 | 消息为: {"id":"551","workName":"task-551"} 正常执行！
当前任务：544 | 消息为: {"id":"544","workName":"task-544"} 正常执行！
当前任务：541 | 消息为: {"id":"541","workName":"task-541"} 正常执行！
当前任务：558 | 消息为: {"id":"558","workName":"task-558"} 正常执行！
当前任务：540 | 消息为: {"id":"540","workName":"task-540"} 正常执行！
当前任务：549 | 消息为: {"id":"549","workName":"task-549"} 正常执行！
当前任务：553 | 消息为: {"id":"553","workName":"task-553"} 正常执行！
当前任务：548 | 消息为: {"id":"548","workName":"task-548"} 正常执行！
当前任务：555 | 消息为: {"id":"555","workName":"task-555"} 正常执行！
当前任务：543 | 消息为: {"id":"543","workName":"task-543"} 正常执行！
当前任务：552 | 消息为: {"id":"552","workName":"task-552"} 正常执行！
重新放入队列后的队列大小为: 8
当前任务：547 | 消息为: {"id":"547","workName":"task-547"} 正常执行！
当前任务：546 | 消息为: {"id":"546","workName":"task-546"} 正常执行！
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 8
重新放入队列前的队列大小为: 10
581 被丢弃! 此时消息为: {"id":"581","workName":"task-581"}
587 被丢弃! 此时消息为: {"id":"587","workName":"task-587"}
590 被丢弃! 此时消息为: {"id":"590","workName":"task-590"}
当前任务：562 | 消息为: {"id":"562","workName":"task-562"} 正常执行！
当前任务：574 | 消息为: {"id":"574","workName":"task-574"} 正常执行！
当前任务：570 | 消息为: {"id":"570","workName":"task-570"} 正常执行！
当前任务：573 | 消息为: {"id":"573","workName":"task-573"} 正常执行！
当前任务：579 | 消息为: {"id":"579","workName":"task-579"} 正常执行！
当前任务：572 | 消息为: {"id":"572","workName":"task-572"} 正常执行！
当前任务：569 | 消息为: {"id":"569","workName":"task-569"} 正常执行！
当前任务：578 | 消息为: {"id":"578","workName":"task-578"} 正常执行！
当前任务：563 | 消息为: {"id":"563","workName":"task-563"} 正常执行！
当前任务：571 | 消息为: {"id":"571","workName":"task-571"} 正常执行！
当前任务：567 | 消息为: {"id":"567","workName":"task-567"} 正常执行！
当前任务：575 | 消息为: {"id":"575","workName":"task-575"} 正常执行！
当前任务：577 | 消息为: {"id":"577","workName":"task-577"} 正常执行！
当前任务：560 | 消息为: {"id":"560","workName":"task-560"} 正常执行！
当前任务：566 | 消息为: {"id":"566","workName":"task-566"} 正常执行！
当前任务：576 | 消息为: {"id":"576","workName":"task-576"} 正常执行！
当前任务：565 | 消息为: {"id":"565","workName":"task-565"} 正常执行！
当前任务：568 | 消息为: {"id":"568","workName":"task-568"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：564 | 消息为: {"id":"564","workName":"task-564"} 正常执行！
当前任务：561 | 消息为: {"id":"561","workName":"task-561"} 正常执行！
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 8
重新放入队列前的队列大小为: 10
601 被丢弃! 此时消息为: {"id":"601","workName":"task-601"}
607 被丢弃! 此时消息为: {"id":"607","workName":"task-607"}
610 被丢弃! 此时消息为: {"id":"610","workName":"task-610"}
当前任务：591 | 消息为: {"id":"591","workName":"task-591"} 正常执行！
当前任务：596 | 消息为: {"id":"596","workName":"task-596"} 正常执行！
当前任务：580 | 消息为: {"id":"580","workName":"task-580"} 正常执行！
当前任务：581 | 消息为: {"id":"581","workName":"task-581"} 正常执行！
当前任务：588 | 消息为: {"id":"588","workName":"task-588"} 正常执行！
当前任务：597 | 消息为: {"id":"597","workName":"task-597"} 正常执行！
当前任务：595 | 消息为: {"id":"595","workName":"task-595"} 正常执行！
当前任务：589 | 消息为: {"id":"589","workName":"task-589"} 正常执行！
当前任务：590 | 消息为: {"id":"590","workName":"task-590"} 正常执行！
当前任务：583 | 消息为: {"id":"583","workName":"task-583"} 正常执行！
当前任务：584 | 消息为: {"id":"584","workName":"task-584"} 正常执行！
当前任务：593 | 消息为: {"id":"593","workName":"task-593"} 正常执行！
当前任务：598 | 消息为: {"id":"598","workName":"task-598"} 正常执行！
当前任务：599 | 消息为: {"id":"599","workName":"task-599"} 正常执行！
当前任务：592 | 消息为: {"id":"592","workName":"task-592"} 正常执行！
当前任务：594 | 消息为: {"id":"594","workName":"task-594"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：585 | 消息为: {"id":"585","workName":"task-585"} 正常执行！
当前任务：586 | 消息为: {"id":"586","workName":"task-586"} 正常执行！
当前任务：587 | 消息为: {"id":"587","workName":"task-587"} 正常执行！
当前任务：582 | 消息为: {"id":"582","workName":"task-582"} 正常执行！
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 5
重新放入队列前的队列大小为: 9
重新放入队列后的队列大小为: 10
重新放入队列前的队列大小为: 10
622 被丢弃! 此时消息为: {"id":"622","workName":"task-622"}
629 被丢弃! 此时消息为: {"id":"629","workName":"task-629"}
630 被丢弃! 此时消息为: {"id":"630","workName":"task-630"}
当前任务：611 | 消息为: {"id":"611","workName":"task-611"} 正常执行！
当前任务：601 | 消息为: {"id":"601","workName":"task-601"} 正常执行！
当前任务：600 | 消息为: {"id":"600","workName":"task-600"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：608 | 消息为: {"id":"608","workName":"task-608"} 正常执行！
当前任务：614 | 消息为: {"id":"614","workName":"task-614"} 正常执行！
当前任务：610 | 消息为: {"id":"610","workName":"task-610"} 正常执行！
当前任务：605 | 消息为: {"id":"605","workName":"task-605"} 正常执行！
当前任务：612 | 消息为: {"id":"612","workName":"task-612"} 正常执行！
当前任务：606 | 消息为: {"id":"606","workName":"task-606"} 正常执行！
当前任务：607 | 消息为: {"id":"607","workName":"task-607"} 正常执行！
当前任务：615 | 消息为: {"id":"615","workName":"task-615"} 正常执行！
当前任务：616 | 消息为: {"id":"616","workName":"task-616"} 正常执行！
当前任务：604 | 消息为: {"id":"604","workName":"task-604"} 正常执行！
重新放入队列前的队列大小为: 8
当前任务：617 | 消息为: {"id":"617","workName":"task-617"} 正常执行！
当前任务：619 | 消息为: {"id":"619","workName":"task-619"} 正常执行！
当前任务：602 | 消息为: {"id":"602","workName":"task-602"} 正常执行！
当前任务：609 | 消息为: {"id":"609","workName":"task-609"} 正常执行！
当前任务：613 | 消息为: {"id":"613","workName":"task-613"} 正常执行！
当前任务：618 | 消息为: {"id":"618","workName":"task-618"} 正常执行！
当前任务：603 | 消息为: {"id":"603","workName":"task-603"} 正常执行！
重新放入队列后的队列大小为: 1
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 7
重新放入队列前的队列大小为: 9
重新放入队列后的队列大小为: 10
重新放入队列前的队列大小为: 10
633 被丢弃! 此时消息为: {"id":"633","workName":"task-633"}
644 被丢弃! 此时消息为: {"id":"644","workName":"task-644"}
649 被丢弃! 此时消息为: {"id":"649","workName":"task-649"}
650 被丢弃! 此时消息为: {"id":"650","workName":"task-650"}
当前任务：628 | 消息为: {"id":"628","workName":"task-628"} 正常执行！
当前任务：633 | 消息为: {"id":"633","workName":"task-633"} 正常执行！
当前任务：631 | 消息为: {"id":"631","workName":"task-631"} 正常执行！
当前任务：636 | 消息为: {"id":"636","workName":"task-636"} 正常执行！
当前任务：622 | 消息为: {"id":"622","workName":"task-622"} 正常执行！
当前任务：630 | 消息为: {"id":"630","workName":"task-630"} 正常执行！
当前任务：621 | 消息为: {"id":"621","workName":"task-621"} 正常执行！
当前任务：634 | 消息为: {"id":"634","workName":"task-634"} 正常执行！
当前任务：639 | 消息为: {"id":"639","workName":"task-639"} 正常执行！
当前任务：626 | 消息为: {"id":"626","workName":"task-626"} 正常执行！
当前任务：624 | 消息为: {"id":"624","workName":"task-624"} 正常执行！
当前任务：627 | 消息为: {"id":"627","workName":"task-627"} 正常执行！
当前任务：620 | 消息为: {"id":"620","workName":"task-620"} 正常执行！
当前任务：623 | 消息为: {"id":"623","workName":"task-623"} 正常执行！
当前任务：637 | 消息为: {"id":"637","workName":"task-637"} 正常执行！
当前任务：629 | 消息为: {"id":"629","workName":"task-629"} 正常执行！
重新放入队列后的队列大小为: 8
当前任务：632 | 消息为: {"id":"632","workName":"task-632"} 正常执行！
当前任务：635 | 消息为: {"id":"635","workName":"task-635"} 正常执行！
当前任务：638 | 消息为: {"id":"638","workName":"task-638"} 正常执行！
当前任务：625 | 消息为: {"id":"625","workName":"task-625"} 正常执行！
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 7
重新放入队列前的队列大小为: 6
重新放入队列后的队列大小为: 7
重新放入队列前的队列大小为: 10
661 被丢弃! 此时消息为: {"id":"661","workName":"task-661"}
666 被丢弃! 此时消息为: {"id":"666","workName":"task-666"}
670 被丢弃! 此时消息为: {"id":"670","workName":"task-670"}
当前任务：647 | 消息为: {"id":"647","workName":"task-647"} 正常执行！
当前任务：658 | 消息为: {"id":"658","workName":"task-658"} 正常执行！
当前任务：652 | 消息为: {"id":"652","workName":"task-652"} 正常执行！
当前任务：640 | 消息为: {"id":"640","workName":"task-640"} 正常执行！
当前任务：656 | 消息为: {"id":"656","workName":"task-656"} 正常执行！
当前任务：642 | 消息为: {"id":"642","workName":"task-642"} 正常执行！
当前任务：646 | 消息为: {"id":"646","workName":"task-646"} 正常执行！
当前任务：653 | 消息为: {"id":"653","workName":"task-653"} 正常执行！
当前任务：645 | 消息为: {"id":"645","workName":"task-645"} 正常执行！
当前任务：649 | 消息为: {"id":"649","workName":"task-649"} 正常执行！
当前任务：643 | 消息为: {"id":"643","workName":"task-643"} 正常执行！
当前任务：650 | 消息为: {"id":"650","workName":"task-650"} 正常执行！
当前任务：651 | 消息为: {"id":"651","workName":"task-651"} 正常执行！
当前任务：655 | 消息为: {"id":"655","workName":"task-655"} 正常执行！
当前任务：654 | 消息为: {"id":"654","workName":"task-654"} 正常执行！
当前任务：648 | 消息为: {"id":"648","workName":"task-648"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：657 | 消息为: {"id":"657","workName":"task-657"} 正常执行！
当前任务：644 | 消息为: {"id":"644","workName":"task-644"} 正常执行！
当前任务：641 | 消息为: {"id":"641","workName":"task-641"} 正常执行！
当前任务：659 | 消息为: {"id":"659","workName":"task-659"} 正常执行！
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10
681 被丢弃! 此时消息为: {"id":"681","workName":"task-681"}
690 被丢弃! 此时消息为: {"id":"690","workName":"task-690"}
当前任务：676 | 消息为: {"id":"676","workName":"task-676"} 正常执行！
当前任务：661 | 消息为: {"id":"661","workName":"task-661"} 正常执行！
当前任务：665 | 消息为: {"id":"665","workName":"task-665"} 正常执行！
当前任务：663 | 消息为: {"id":"663","workName":"task-663"} 正常执行！
当前任务：664 | 消息为: {"id":"664","workName":"task-664"} 正常执行！
当前任务：662 | 消息为: {"id":"662","workName":"task-662"} 正常执行！
当前任务：673 | 消息为: {"id":"673","workName":"task-673"} 正常执行！
当前任务：671 | 消息为: {"id":"671","workName":"task-671"} 正常执行！
当前任务：667 | 消息为: {"id":"667","workName":"task-667"} 正常执行！
当前任务：679 | 消息为: {"id":"679","workName":"task-679"} 正常执行！
当前任务：669 | 消息为: {"id":"669","workName":"task-669"} 正常执行！
当前任务：668 | 消息为: {"id":"668","workName":"task-668"} 正常执行！
当前任务：660 | 消息为: {"id":"660","workName":"task-660"} 正常执行！
当前任务：666 | 消息为: {"id":"666","workName":"task-666"} 正常执行！
当前任务：677 | 消息为: {"id":"677","workName":"task-677"} 正常执行！
当前任务：670 | 消息为: {"id":"670","workName":"task-670"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：672 | 消息为: {"id":"672","workName":"task-672"} 正常执行！
当前任务：675 | 消息为: {"id":"675","workName":"task-675"} 正常执行！
当前任务：678 | 消息为: {"id":"678","workName":"task-678"} 正常执行！
当前任务：674 | 消息为: {"id":"674","workName":"task-674"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 3
重新放入队列前的队列大小为: 9
重新放入队列后的队列大小为: 10
重新放入队列前的队列大小为: 10
701 被丢弃! 此时消息为: {"id":"701","workName":"task-701"}
709 被丢弃! 此时消息为: {"id":"709","workName":"task-709"}
710 被丢弃! 此时消息为: {"id":"710","workName":"task-710"}
当前任务：689 | 消息为: {"id":"689","workName":"task-689"} 正常执行！
当前任务：691 | 消息为: {"id":"691","workName":"task-691"} 正常执行！
当前任务：682 | 消息为: {"id":"682","workName":"task-682"} 正常执行！
当前任务：688 | 消息为: {"id":"688","workName":"task-688"} 正常执行！
当前任务：681 | 消息为: {"id":"681","workName":"task-681"} 正常执行！
当前任务：687 | 消息为: {"id":"687","workName":"task-687"} 正常执行！
当前任务：685 | 消息为: {"id":"685","workName":"task-685"} 正常执行！
当前任务：696 | 消息为: {"id":"696","workName":"task-696"} 正常执行！
当前任务：690 | 消息为: {"id":"690","workName":"task-690"} 正常执行！
当前任务：686 | 消息为: {"id":"686","workName":"task-686"} 正常执行！
当前任务：692 | 消息为: {"id":"692","workName":"task-692"} 正常执行！
当前任务：693 | 消息为: {"id":"693","workName":"task-693"} 正常执行！
当前任务：694 | 消息为: {"id":"694","workName":"task-694"} 正常执行！
当前任务：697 | 消息为: {"id":"697","workName":"task-697"} 正常执行！
当前任务：698 | 消息为: {"id":"698","workName":"task-698"} 正常执行！
重新放入队列后的队列大小为: 8
当前任务：695 | 消息为: {"id":"695","workName":"task-695"} 正常执行！
当前任务：699 | 消息为: {"id":"699","workName":"task-699"} 正常执行！
当前任务：684 | 消息为: {"id":"684","workName":"task-684"} 正常执行！
当前任务：680 | 消息为: {"id":"680","workName":"task-680"} 正常执行！
当前任务：683 | 消息为: {"id":"683","workName":"task-683"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10
721 被丢弃! 此时消息为: {"id":"721","workName":"task-721"}
730 被丢弃! 此时消息为: {"id":"730","workName":"task-730"}
740 被丢弃! 此时消息为: {"id":"740","workName":"task-740"}
750 被丢弃! 此时消息为: {"id":"750","workName":"task-750"}
当前任务：709 | 消息为: {"id":"709","workName":"task-709"} 正常执行！
当前任务：716 | 消息为: {"id":"716","workName":"task-716"} 正常执行！
当前任务：710 | 消息为: {"id":"710","workName":"task-710"} 正常执行！
当前任务：708 | 消息为: {"id":"708","workName":"task-708"} 正常执行！
当前任务：712 | 消息为: {"id":"712","workName":"task-712"} 正常执行！
当前任务：711 | 消息为: {"id":"711","workName":"task-711"} 正常执行！
当前任务：719 | 消息为: {"id":"719","workName":"task-719"} 正常执行！
当前任务：707 | 消息为: {"id":"707","workName":"task-707"} 正常执行！
当前任务：717 | 消息为: {"id":"717","workName":"task-717"} 正常执行！
当前任务：703 | 消息为: {"id":"703","workName":"task-703"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：715 | 消息为: {"id":"715","workName":"task-715"} 正常执行！
当前任务：700 | 消息为: {"id":"700","workName":"task-700"} 正常执行！
当前任务：704 | 消息为: {"id":"704","workName":"task-704"} 正常执行！
重新放入队列前的队列大小为: 8
当前任务：701 | 消息为: {"id":"701","workName":"task-701"} 正常执行！
当前任务：702 | 消息为: {"id":"702","workName":"task-702"} 正常执行！
当前任务：705 | 消息为: {"id":"705","workName":"task-705"} 正常执行！
当前任务：714 | 消息为: {"id":"714","workName":"task-714"} 正常执行！
当前任务：713 | 消息为: {"id":"713","workName":"task-713"} 正常执行！
当前任务：718 | 消息为: {"id":"718","workName":"task-718"} 正常执行！
当前任务：706 | 消息为: {"id":"706","workName":"task-706"} 正常执行！
重新放入队列后的队列大小为: 8
重新放入队列前的队列大小为: 10
当前任务：733 | 消息为: {"id":"733","workName":"task-733"} 正常执行！
当前任务：727 | 消息为: {"id":"727","workName":"task-727"} 正常执行！
当前任务：724 | 消息为: {"id":"724","workName":"task-724"} 正常执行！
当前任务：734 | 消息为: {"id":"734","workName":"task-734"} 正常执行！
当前任务：731 | 消息为: {"id":"731","workName":"task-731"} 正常执行！
当前任务：726 | 消息为: {"id":"726","workName":"task-726"} 正常执行！
当前任务：723 | 消息为: {"id":"723","workName":"task-723"} 正常执行！
当前任务：721 | 消息为: {"id":"721","workName":"task-721"} 正常执行！
当前任务：729 | 消息为: {"id":"729","workName":"task-729"} 正常执行！
当前任务：722 | 消息为: {"id":"722","workName":"task-722"} 正常执行！
当前任务：736 | 消息为: {"id":"736","workName":"task-736"} 正常执行！
当前任务：732 | 消息为: {"id":"732","workName":"task-732"} 正常执行！
当前任务：737 | 消息为: {"id":"737","workName":"task-737"} 正常执行！
当前任务：730 | 消息为: {"id":"730","workName":"task-730"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：739 | 消息为: {"id":"739","workName":"task-739"} 正常执行！
当前任务：738 | 消息为: {"id":"738","workName":"task-738"} 正常执行！
当前任务：735 | 消息为: {"id":"735","workName":"task-735"} 正常执行！
重新放入队列前的队列大小为: 6
当前任务：720 | 消息为: {"id":"720","workName":"task-720"} 正常执行！
当前任务：728 | 消息为: {"id":"728","workName":"task-728"} 正常执行！
当前任务：725 | 消息为: {"id":"725","workName":"task-725"} 正常执行！
重新放入队列后的队列大小为: 5
重新放入队列前的队列大小为: 10
761 被丢弃! 此时消息为: {"id":"761","workName":"task-761"}
770 被丢弃! 此时消息为: {"id":"770","workName":"task-770"}
当前任务：759 | 消息为: {"id":"759","workName":"task-759"} 正常执行！
当前任务：750 | 消息为: {"id":"750","workName":"task-750"} 正常执行！
当前任务：752 | 消息为: {"id":"752","workName":"task-752"} 正常执行！
当前任务：742 | 消息为: {"id":"742","workName":"task-742"} 正常执行！
当前任务：749 | 消息为: {"id":"749","workName":"task-749"} 正常执行！
当前任务：758 | 消息为: {"id":"758","workName":"task-758"} 正常执行！
当前任务：746 | 消息为: {"id":"746","workName":"task-746"} 正常执行！
当前任务：745 | 消息为: {"id":"745","workName":"task-745"} 正常执行！
当前任务：754 | 消息为: {"id":"754","workName":"task-754"} 正常执行！
当前任务：755 | 消息为: {"id":"755","workName":"task-755"} 正常执行！
当前任务：748 | 消息为: {"id":"748","workName":"task-748"} 正常执行！
当前任务：756 | 消息为: {"id":"756","workName":"task-756"} 正常执行！
当前任务：757 | 消息为: {"id":"757","workName":"task-757"} 正常执行！
当前任务：740 | 消息为: {"id":"740","workName":"task-740"} 正常执行！
当前任务：744 | 消息为: {"id":"744","workName":"task-744"} 正常执行！
当前任务：741 | 消息为: {"id":"741","workName":"task-741"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：747 | 消息为: {"id":"747","workName":"task-747"} 正常执行！
当前任务：743 | 消息为: {"id":"743","workName":"task-743"} 正常执行！
当前任务：751 | 消息为: {"id":"751","workName":"task-751"} 正常执行！
当前任务：753 | 消息为: {"id":"753","workName":"task-753"} 正常执行！
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10
781 被丢弃! 此时消息为: {"id":"781","workName":"task-781"}
790 被丢弃! 此时消息为: {"id":"790","workName":"task-790"}
当前任务：774 | 消息为: {"id":"774","workName":"task-774"} 正常执行！
当前任务：764 | 消息为: {"id":"764","workName":"task-764"} 正常执行！
当前任务：765 | 消息为: {"id":"765","workName":"task-765"} 正常执行！
当前任务：767 | 消息为: {"id":"767","workName":"task-767"} 正常执行！
当前任务：761 | 消息为: {"id":"761","workName":"task-761"} 正常执行！
当前任务：766 | 消息为: {"id":"766","workName":"task-766"} 正常执行！
当前任务：779 | 消息为: {"id":"779","workName":"task-779"} 正常执行！
当前任务：776 | 消息为: {"id":"776","workName":"task-776"} 正常执行！
当前任务：773 | 消息为: {"id":"773","workName":"task-773"} 正常执行！
当前任务：763 | 消息为: {"id":"763","workName":"task-763"} 正常执行！
当前任务：772 | 消息为: {"id":"772","workName":"task-772"} 正常执行！
当前任务：760 | 消息为: {"id":"760","workName":"task-760"} 正常执行！
当前任务：775 | 消息为: {"id":"775","workName":"task-775"} 正常执行！
当前任务：778 | 消息为: {"id":"778","workName":"task-778"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：768 | 消息为: {"id":"768","workName":"task-768"} 正常执行！
当前任务：771 | 消息为: {"id":"771","workName":"task-771"} 正常执行！
当前任务：777 | 消息为: {"id":"777","workName":"task-777"} 正常执行！
重新放入队列前的队列大小为: 5
当前任务：762 | 消息为: {"id":"762","workName":"task-762"} 正常执行！
当前任务：770 | 消息为: {"id":"770","workName":"task-770"} 正常执行！
当前任务：769 | 消息为: {"id":"769","workName":"task-769"} 正常执行！
重新放入队列后的队列大小为: 5
重新放入队列前的队列大小为: 10
801 被丢弃! 此时消息为: {"id":"801","workName":"task-801"}
810 被丢弃! 此时消息为: {"id":"810","workName":"task-810"}
当前任务：783 | 消息为: {"id":"783","workName":"task-783"} 正常执行！
当前任务：780 | 消息为: {"id":"780","workName":"task-780"} 正常执行！
当前任务：797 | 消息为: {"id":"797","workName":"task-797"} 正常执行！
当前任务：784 | 消息为: {"id":"784","workName":"task-784"} 正常执行！
当前任务：786 | 消息为: {"id":"786","workName":"task-786"} 正常执行！
当前任务：798 | 消息为: {"id":"798","workName":"task-798"} 正常执行！
当前任务：785 | 消息为: {"id":"785","workName":"task-785"} 正常执行！
当前任务：789 | 消息为: {"id":"789","workName":"task-789"} 正常执行！
当前任务：795 | 消息为: {"id":"795","workName":"task-795"} 正常执行！
当前任务：799 | 消息为: {"id":"799","workName":"task-799"} 正常执行！
当前任务：790 | 消息为: {"id":"790","workName":"task-790"} 正常执行！
当前任务：782 | 消息为: {"id":"782","workName":"task-782"} 正常执行！
当前任务：788 | 消息为: {"id":"788","workName":"task-788"} 正常执行！
当前任务：796 | 消息为: {"id":"796","workName":"task-796"} 正常执行！
当前任务：787 | 消息为: {"id":"787","workName":"task-787"} 正常执行！
当前任务：791 | 消息为: {"id":"791","workName":"task-791"} 正常执行！
当前任务：781 | 消息为: {"id":"781","workName":"task-781"} 正常执行！
重新放入队列后的队列大小为: 8
当前任务：794 | 消息为: {"id":"794","workName":"task-794"} 正常执行！
当前任务：792 | 消息为: {"id":"792","workName":"task-792"} 正常执行！
当前任务：793 | 消息为: {"id":"793","workName":"task-793"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10
821 被丢弃! 此时消息为: {"id":"821","workName":"task-821"}
830 被丢弃! 此时消息为: {"id":"830","workName":"task-830"}
当前任务：805 | 消息为: {"id":"805","workName":"task-805"} 正常执行！
当前任务：803 | 消息为: {"id":"803","workName":"task-803"} 正常执行！
当前任务：801 | 消息为: {"id":"801","workName":"task-801"} 正常执行！
当前任务：810 | 消息为: {"id":"810","workName":"task-810"} 正常执行！
当前任务：812 | 消息为: {"id":"812","workName":"task-812"} 正常执行！
当前任务：807 | 消息为: {"id":"807","workName":"task-807"} 正常执行！
当前任务：802 | 消息为: {"id":"802","workName":"task-802"} 正常执行！
当前任务：808 | 消息为: {"id":"808","workName":"task-808"} 正常执行！
当前任务：814 | 消息为: {"id":"814","workName":"task-814"} 正常执行！
当前任务：806 | 消息为: {"id":"806","workName":"task-806"} 正常执行！
当前任务：815 | 消息为: {"id":"815","workName":"task-815"} 正常执行！
当前任务：813 | 消息为: {"id":"813","workName":"task-813"} 正常执行！
当前任务：817 | 消息为: {"id":"817","workName":"task-817"} 正常执行！
当前任务：811 | 消息为: {"id":"811","workName":"task-811"} 正常执行！
当前任务：819 | 消息为: {"id":"819","workName":"task-819"} 正常执行！
当前任务：818 | 消息为: {"id":"818","workName":"task-818"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：804 | 消息为: {"id":"804","workName":"task-804"} 正常执行！
当前任务：800 | 消息为: {"id":"800","workName":"task-800"} 正常执行！
当前任务：809 | 消息为: {"id":"809","workName":"task-809"} 正常执行！
当前任务：816 | 消息为: {"id":"816","workName":"task-816"} 正常执行！
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10
841 被丢弃! 此时消息为: {"id":"841","workName":"task-841"}
850 被丢弃! 此时消息为: {"id":"850","workName":"task-850"}
当前任务：836 | 消息为: {"id":"836","workName":"task-836"} 正常执行！
当前任务：833 | 消息为: {"id":"833","workName":"task-833"} 正常执行！
当前任务：824 | 消息为: {"id":"824","workName":"task-824"} 正常执行！
当前任务：822 | 消息为: {"id":"822","workName":"task-822"} 正常执行！
当前任务：830 | 消息为: {"id":"830","workName":"task-830"} 正常执行！
当前任务：825 | 消息为: {"id":"825","workName":"task-825"} 正常执行！
当前任务：832 | 消息为: {"id":"832","workName":"task-832"} 正常执行！
当前任务：829 | 消息为: {"id":"829","workName":"task-829"} 正常执行！
当前任务：828 | 消息为: {"id":"828","workName":"task-828"} 正常执行！
当前任务：838 | 消息为: {"id":"838","workName":"task-838"} 正常执行！
当前任务：834 | 消息为: {"id":"834","workName":"task-834"} 正常执行！
当前任务：835 | 消息为: {"id":"835","workName":"task-835"} 正常执行！
当前任务：837 | 消息为: {"id":"837","workName":"task-837"} 正常执行！
当前任务：839 | 消息为: {"id":"839","workName":"task-839"} 正常执行！
当前任务：827 | 消息为: {"id":"827","workName":"task-827"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：826 | 消息为: {"id":"826","workName":"task-826"} 正常执行！
当前任务：831 | 消息为: {"id":"831","workName":"task-831"} 正常执行！
重新放入队列前的队列大小为: 5
当前任务：823 | 消息为: {"id":"823","workName":"task-823"} 正常执行！
当前任务：821 | 消息为: {"id":"821","workName":"task-821"} 正常执行！
当前任务：820 | 消息为: {"id":"820","workName":"task-820"} 正常执行！
重新放入队列后的队列大小为: 6
重新放入队列前的队列大小为: 10
862 被丢弃! 此时消息为: {"id":"862","workName":"task-862"}
870 被丢弃! 此时消息为: {"id":"870","workName":"task-870"}
881 被丢弃! 此时消息为: {"id":"881","workName":"task-881"}
890 被丢弃! 此时消息为: {"id":"890","workName":"task-890"}
当前任务：857 | 消息为: {"id":"857","workName":"task-857"} 正常执行！
当前任务：849 | 消息为: {"id":"849","workName":"task-849"} 正常执行！
当前任务：845 | 消息为: {"id":"845","workName":"task-845"} 正常执行！
当前任务：843 | 消息为: {"id":"843","workName":"task-843"} 正常执行！
当前任务：841 | 消息为: {"id":"841","workName":"task-841"} 正常执行！
当前任务：848 | 消息为: {"id":"848","workName":"task-848"} 正常执行！
当前任务：855 | 消息为: {"id":"855","workName":"task-855"} 正常执行！
当前任务：854 | 消息为: {"id":"854","workName":"task-854"} 正常执行！
当前任务：842 | 消息为: {"id":"842","workName":"task-842"} 正常执行！
当前任务：856 | 消息为: {"id":"856","workName":"task-856"} 正常执行！
当前任务：851 | 消息为: {"id":"851","workName":"task-851"} 正常执行！
当前任务：844 | 消息为: {"id":"844","workName":"task-844"} 正常执行！
当前任务：846 | 消息为: {"id":"846","workName":"task-846"} 正常执行！
当前任务：840 | 消息为: {"id":"840","workName":"task-840"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：858 | 消息为: {"id":"858","workName":"task-858"} 正常执行！
当前任务：850 | 消息为: {"id":"850","workName":"task-850"} 正常执行！
当前任务：853 | 消息为: {"id":"853","workName":"task-853"} 正常执行！
当前任务：859 | 消息为: {"id":"859","workName":"task-859"} 正常执行！
当前任务：847 | 消息为: {"id":"847","workName":"task-847"} 正常执行！
当前任务：852 | 消息为: {"id":"852","workName":"task-852"} 正常执行！
重新放入队列前的队列大小为: 4
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10
当前任务：867 | 消息为: {"id":"867","workName":"task-867"} 正常执行！
当前任务：864 | 消息为: {"id":"864","workName":"task-864"} 正常执行！
当前任务：879 | 消息为: {"id":"879","workName":"task-879"} 正常执行！
当前任务：869 | 消息为: {"id":"869","workName":"task-869"} 正常执行！
当前任务：865 | 消息为: {"id":"865","workName":"task-865"} 正常执行！
当前任务：873 | 消息为: {"id":"873","workName":"task-873"} 正常执行！
当前任务：860 | 消息为: {"id":"860","workName":"task-860"} 正常执行！
当前任务：861 | 消息为: {"id":"861","workName":"task-861"} 正常执行！
当前任务：872 | 消息为: {"id":"872","workName":"task-872"} 正常执行！
当前任务：863 | 消息为: {"id":"863","workName":"task-863"} 正常执行！
当前任务：868 | 消息为: {"id":"868","workName":"task-868"} 正常执行！
当前任务：877 | 消息为: {"id":"877","workName":"task-877"} 正常执行！
当前任务：871 | 消息为: {"id":"871","workName":"task-871"} 正常执行！
当前任务：878 | 消息为: {"id":"878","workName":"task-878"} 正常执行！
当前任务：875 | 消息为: {"id":"875","workName":"task-875"} 正常执行！
当前任务：866 | 消息为: {"id":"866","workName":"task-866"} 正常执行！
当前任务：862 | 消息为: {"id":"862","workName":"task-862"} 正常执行！
当前任务：876 | 消息为: {"id":"876","workName":"task-876"} 正常执行！
当前任务：874 | 消息为: {"id":"874","workName":"task-874"} 正常执行！
当前任务：870 | 消息为: {"id":"870","workName":"task-870"} 正常执行！
重新放入队列后的队列大小为: 9
重新放入队列前的队列大小为: 8
重新放入队列后的队列大小为: 8
重新放入队列前的队列大小为: 7
重新放入队列后的队列大小为: 7
重新放入队列前的队列大小为: 10
901 被丢弃! 此时消息为: {"id":"901","workName":"task-901"}
905 被丢弃! 此时消息为: {"id":"905","workName":"task-905"}
910 被丢弃! 此时消息为: {"id":"910","workName":"task-910"}
当前任务：897 | 消息为: {"id":"897","workName":"task-897"} 正常执行！
当前任务：888 | 消息为: {"id":"888","workName":"task-888"} 正常执行！
当前任务：887 | 消息为: {"id":"887","workName":"task-887"} 正常执行！
当前任务：892 | 消息为: {"id":"892","workName":"task-892"} 正常执行！
当前任务：891 | 消息为: {"id":"891","workName":"task-891"} 正常执行！
当前任务：895 | 消息为: {"id":"895","workName":"task-895"} 正常执行！
当前任务：896 | 消息为: {"id":"896","workName":"task-896"} 正常执行！
当前任务：894 | 消息为: {"id":"894","workName":"task-894"} 正常执行！
当前任务：886 | 消息为: {"id":"886","workName":"task-886"} 正常执行！
当前任务：882 | 消息为: {"id":"882","workName":"task-882"} 正常执行！
当前任务：899 | 消息为: {"id":"899","workName":"task-899"} 正常执行！
当前任务：880 | 消息为: {"id":"880","workName":"task-880"} 正常执行！
当前任务：889 | 消息为: {"id":"889","workName":"task-889"} 正常执行！
当前任务：890 | 消息为: {"id":"890","workName":"task-890"} 正常执行！
当前任务：881 | 消息为: {"id":"881","workName":"task-881"} 正常执行！
当前任务：884 | 消息为: {"id":"884","workName":"task-884"} 正常执行！
重新放入队列后的队列大小为: 9
当前任务：885 | 消息为: {"id":"885","workName":"task-885"} 正常执行！
当前任务：893 | 消息为: {"id":"893","workName":"task-893"} 正常执行！
当前任务：898 | 消息为: {"id":"898","workName":"task-898"} 正常执行！
当前任务：883 | 消息为: {"id":"883","workName":"task-883"} 正常执行！
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10
921 被丢弃! 此时消息为: {"id":"921","workName":"task-921"}
930 被丢弃! 此时消息为: {"id":"930","workName":"task-930"}
当前任务：910 | 消息为: {"id":"910","workName":"task-910"} 正常执行！
当前任务：918 | 消息为: {"id":"918","workName":"task-918"} 正常执行！
当前任务：916 | 消息为: {"id":"916","workName":"task-916"} 正常执行！
当前任务：917 | 消息为: {"id":"917","workName":"task-917"} 正常执行！
当前任务：900 | 消息为: {"id":"900","workName":"task-900"} 正常执行！
当前任务：902 | 消息为: {"id":"902","workName":"task-902"} 正常执行！
当前任务：914 | 消息为: {"id":"914","workName":"task-914"} 正常执行！
当前任务：912 | 消息为: {"id":"912","workName":"task-912"} 正常执行！
当前任务：904 | 消息为: {"id":"904","workName":"task-904"} 正常执行！
当前任务：907 | 消息为: {"id":"907","workName":"task-907"} 正常执行！
当前任务：915 | 消息为: {"id":"915","workName":"task-915"} 正常执行！
当前任务：919 | 消息为: {"id":"919","workName":"task-919"} 正常执行！
当前任务：908 | 消息为: {"id":"908","workName":"task-908"} 正常执行！
当前任务：901 | 消息为: {"id":"901","workName":"task-901"} 正常执行！
当前任务：911 | 消息为: {"id":"911","workName":"task-911"} 正常执行！
当前任务：905 | 消息为: {"id":"905","workName":"task-905"} 正常执行！
当前任务：913 | 消息为: {"id":"913","workName":"task-913"} 正常执行！
当前任务：906 | 消息为: {"id":"906","workName":"task-906"} 正常执行！
当前任务：909 | 消息为: {"id":"909","workName":"task-909"} 正常执行！
当前任务：903 | 消息为: {"id":"903","workName":"task-903"} 正常执行！
重新放入队列后的队列大小为: 10

重新放入队列后的队列大小为: 9
当前任务：3484 | 消息为: {"id":"3484","workName":"task-3484"} 正常执行！
当前任务：3487 | 消息为: {"id":"3487","workName":"task-3487"} 正常执行！
当前任务：3482 | 消息为: {"id":"3482","workName":"task-3482"} 正常执行！
当前任务：3485 | 消息为: {"id":"3485","workName":"task-3485"} 正常执行！
重新放入队列前的队列大小为: 5
重新放入队列后的队列大小为: 2
重新放入队列前的队列大小为: 10

重新放入队列前的队列大小为: 10
3661 被丢弃! 此时消息为: {"id":"3661","workName":"task-3661"}
3665 被丢弃! 此时消息为: {"id":"3665","workName":"task-3665"}
3669 被丢弃! 此时消息为: {"id":"3669","workName":"task-3669"}
3670 被丢弃! 此时消息为: {"id":"3670","workName":"task-3670"}

Process finished with exit code -1