spring定时器@Scheduled异步调用方式

@component
public class testtimer {

    @scheduled(cron = "0/1 * *  * * ? ")
    public void test01()
    {
        date date = new date();
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test01定时任务执行开始"));
        try {
            thread.sleep(3000);
        } catch (interruptedexception e) {
            throw new runtimeexception(e);
        }
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test01定时任务执行结束"));
    }

    @scheduled(cron = "0/1 * *  * * ? ")
    public void test02()
    {
        date date = new date();
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test02定时任务执行了"));
    }
}

thread-pool:
  config:
    core-size: 8
    max-size: 16
    queue-capacity: 64
    keep-alive-seconds: 180

import lombok.data;
import org.springframework.boot.context.properties.configurationproperties;
import org.springframework.stereotype.component;

/**
 * @author qf
 * @since 2024/08/20
 */
@component
@configurationproperties(prefix = "thread-pool.config")
@data
public class testthreadpoolconfig {
    private integer coresize;
    private integer maxsize;
    private integer queuecapacity;
    private integer keepaliveseconds;
}

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
import org.springframework.scheduling.annotation.enableasync;
import org.springframework.scheduling.concurrent.threadpooltaskexecutor;

import java.util.concurrent.rejectedexecutionhandler;

/**
 * @author qf
 */
@configuration
@enableasync
public class threadpoolconfig {

    @autowired
    private testthreadpoolconfig testthreadpoolconfig;

    @bean(name = "testexecutor")
    public threadpooltaskexecutor testthreadpoolexecutor() {
        return getasynctaskexecutor("test-executor-", testthreadpoolconfig.getcoresize(),
                testthreadpoolconfig.getmaxsize(), testthreadpoolconfig.getqueuecapacity(),
                testthreadpoolconfig.getkeepaliveseconds(), null);
    }

    /**
     * 统一异步线程池
     *
     * @param threadnameprefix
     * @param corepoolsize
     * @param maxpoolsize
     * @param queuecapacity
     * @param keepaliveseconds
     * @param rejectedexecutionhandler 拒接策略 没有填null
     * @return
     */
    private threadpooltaskexecutor getasynctaskexecutor(string threadnameprefix, int corepoolsize, int maxpoolsize, int queuecapacity, int keepaliveseconds, rejectedexecutionhandler rejectedexecutionhandler) {
        threadpooltaskexecutor taskexecutor = new threadpooltaskexecutor();
        taskexecutor.setcorepoolsize(corepoolsize);
        taskexecutor.setmaxpoolsize(maxpoolsize);
        taskexecutor.setqueuecapacity(queuecapacity);
        taskexecutor.setthreadpriority(thread.max_priority);//线程优先级
        taskexecutor.setdaemon(false);//是否为守护线程
        taskexecutor.setkeepaliveseconds(keepaliveseconds);
        taskexecutor.setthreadnameprefix(threadnameprefix);
        taskexecutor.setrejectedexecutionhandler(rejectedexecutionhandler);
        taskexecutor.initialize();//线程池初始化
        return taskexecutor;
    }
}

import lombok.extern.slf4j.slf4j;
import org.springframework.scheduling.annotation.async;
import org.springframework.scheduling.annotation.scheduled;
import org.springframework.stereotype.component;

import java.text.simpledateformat;
import java.util.date;

/**
 * @author qf
 */
@slf4j
@component
public class testtimer {

    @async("testexecutor")
    @scheduled(cron = "0/1 * *  * * ? ")
    public void test01() {
        date date = new date();
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test01定时任务执行开始"));
        try {
            thread.sleep(3000);
        } catch (interruptedexception e) {
            throw new runtimeexception(e);
        }
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test01定时任务执行结束"));
    }

    @async("testexecutor")
    @scheduled(cron = "0/1 * *  * * ? ")
    public void test02() {
        date date = new date();
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test02定时任务执行了"));
    }
}

import lombok.extern.slf4j.slf4j;
import org.springframework.scheduling.annotation.async;
import org.springframework.scheduling.annotation.scheduled;
import org.springframework.stereotype.component;

import java.text.simpledateformat;
import java.util.date;
import java.util.concurrent.locks.reentrantlock;

/**
 * @author qf
 */
@slf4j
@component
public class testtimer {

    private final reentrantlock timerlock = new reentrantlock();
    @async("testexecutor")
    @scheduled(cron = "0/1 * *  * * ? ")
    public void test01() {
        timerlock.lock();
        date date = new date();
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test01定时任务执行开始"));
        try {
            thread.sleep(3000);
        } catch (interruptedexception e) {
            throw new runtimeexception(e);
        }finally {
            timerlock.unlock();//释放锁
        }
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test01定时任务执行结束"));
    }

    @async("testexecutor")
    @scheduled(cron = "0/1 * *  * * ? ")
    public void test02() {
        date date = new date();
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test02定时任务执行了"));
    }
}

import org.springframework.boot.autoconfigure.batch.batchproperties;
import org.springframework.context.annotation.configuration;
import org.springframework.scheduling.annotation.scheduled;
import org.springframework.scheduling.annotation.schedulingconfigurer;
import org.springframework.scheduling.config.scheduledtaskregistrar;

import java.lang.reflect.method;
import java.util.concurrent.executors;

@configuration
public class scheduleconfig implements schedulingconfigurer {

    /**
     * 计算出带有scheduled注解的方法数量，如果该数量小于默认池大小（20），则使用默认线程池核心数大小20。
     * @param taskregistrar the registrar to be configured.
     */
    @override
    public void configuretasks(scheduledtaskregistrar taskregistrar) {
        method[] methods = batchproperties.job.class.getmethods();
        int defaultpoolsize = 20;
        int corepoolsize = 0;
        if (methods != null && methods.length > 0) {
            system.out.println(methods.length);
            for (method method : methods) {
                scheduled annotation = method.getannotation(scheduled.class);
                if (annotation != null) {
                    corepoolsize++;
                }
            }
            if (defaultpoolsize > corepoolsize) {
                corepoolsize = defaultpoolsize;
            }
        }
        taskregistrar.setscheduler(executors.newscheduledthreadpool(corepoolsize));
    }
}

import lombok.extern.slf4j.slf4j;
import org.springframework.scheduling.annotation.async;
import org.springframework.scheduling.annotation.scheduled;
import org.springframework.stereotype.component;

import java.text.simpledateformat;
import java.util.date;
import java.util.concurrent.locks.reentrantlock;

/**
 * @author qf
 */
@slf4j
@component
public class testtimer {

    @scheduled(cron = "0/1 * *  * * ? ")
    public void test01() {
        date date = new date();
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test01定时任务执行开始"));
        try {
            thread.sleep(3000);
        } catch (interruptedexception e) {
            throw new runtimeexception(e);
        }
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test01定时任务执行结束"));
    }

    @scheduled(cron = "0/1 * *  * * ? ")
    public void test02() {
        date date = new date();
        log.info((new simpledateformat("yyyy-mm-dd hh:mm:ss").format(date) + "test02定时任务执行了"));
    }
}