!414 优化任务队列满时任务拒绝策略 Merge pull request !414 from root/master

若依

2022-01-18 74f991b8c5c0e51ceccf4a0efb8cac0925dd6168

!414 优化任务队列满时任务拒绝策略
Merge pull request !414 from root/master

 ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/SysMenu.java

@@ -3,6 +3,7 @@
import java.util.ArrayList;

import java.util.List;

import javax.validation.constraints.NotBlank;

import javax.validation.constraints.NotNull;

import javax.validation.constraints.Size;

import org.apache.commons.lang3.builder.ToStringBuilder;

import org.apache.commons.lang3.builder.ToStringStyle;

@@ -30,7 +31,7 @@
    private Long parentId;



    /** 显示顺序 */

    private String orderNum;

    private Integer orderNum;



    /** 路由地址 */

    private String path;

@@ -107,13 +108,13 @@
        this.parentId = parentId;

    }



    @NotBlank(message = "显示顺序不能为空")

    public String getOrderNum()

    @NotNull(message = "显示顺序不能为空")

    public Integer getOrderNum()

    {

        return orderNum;

    }



    public void setOrderNum(String orderNum)

    public void setOrderNum(Integer orderNum)

    {

        this.orderNum = orderNum;

    }


 ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java

@@ -1,13 +1,14 @@
package com.ruoyi.framework.config;



import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.ScheduledThreadPoolExecutor;

import java.util.concurrent.ThreadPoolExecutor;

import com.ruoyi.common.utils.Threads;

import org.apache.commons.lang3.concurrent.BasicThreadFactory;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import com.ruoyi.common.utils.Threads;



import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.ScheduledThreadPoolExecutor;

import java.util.concurrent.ThreadPoolExecutor;



/**

 * 线程池配置

@@ -49,7 +50,8 @@
    protected ScheduledExecutorService scheduledExecutorService()

    {

        return new ScheduledThreadPoolExecutor(corePoolSize,

                new BasicThreadFactory.Builder().namingPattern("schedule-pool-%d").daemon(true).build())

                new BasicThreadFactory.Builder().namingPattern("schedule-pool-%d").daemon(true).build(),

                new ThreadPoolExecutor.CallerRunsPolicy())

        {

            @Override

            protected void afterExecute(Runnable r, Throwable t)