package com.test.domi.config;

import org.springframework.beans.factory.annotation.Configurable;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;

import java.util.Date;

@Component

@Configurable

@EnableScheduling

public class ScheduledTasks {

    //每30秒执行一次

    @Scheduled(fixedRate = 1000 * 30)

    public void reportCurrentTime(){

        System.out.println ("Scheduling Tasks Examples: The time is now " + dateFormat ().format (new Date ()));

    }

    //在固定时间执行

    @Scheduled(cron = "0 */1 *  * * * ")

    public void reportCurrentByCron(){

        System.out.println ("Scheduling Tasks Examples By Cron: The time is now " + dateFormat ().format (new Date()));

    }

    private SimpleDateFormat dateFormat(){

        return new SimpleDateFormat ("HH:mm:ss");

    }

}

Scheduling Tasks Examples: The time is now 11:55:54

Scheduling Tasks Examples By Cron: The time is now 11:56:00

Scheduling Tasks Examples: The time is now 11:56:24

Scheduling Tasks Examples: The time is now 11:56:54

Scheduling Tasks Examples By Cron: The time is now 11:57:00

 //每30秒执行一次

    @Async("taskExecutor")

    @Scheduled(fixedRate = 1000 * 3)

    public void reportCurrentTime(){

        System.out.println ("线程" + Thread.currentThread().getName() + "开始执行定时任务===&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&7&&&====》"

                + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));

        long start = System.currentTimeMillis();

        Future<Boolean> isOk1;

        Future<Boolean> isOk2;

   。 。。。。。。。。。省略。。。。。。。

@Component

@Configuration

@EnableScheduling

public class AutoConvertTask {

    private static final Logger logger = LoggerFactory.getLogger(AutoConvertTask.class);

    @Autowired

    private RedisTemplate redisTemplate;

    private static final String LOCK = "task-job-lock";

    private static final String KEY = "tasklock";

    @Scheduled(cron = "0 0 0 * * ? ")

    public void autoConvertJob() {

        boolean lock = false;

        try {

            lock = redisTemplate.opsForValue().setIfAbsent(KEY, LOCK);

            logger.info("是否获取到锁:" + lock);

            if (lock) {

                List<GameHistory> historyList = historyService.findTenDaysAgoUntreated();

                for (GameHistory history : historyList) {

                    update(history);

                }

            } else {

                logger.info("没有获取到锁，不执行任务!");

                return;

            }

        } finally {

            if (lock) {

                redisTemplate.delete(KEY);

                logger.info("任务结束，释放锁!");

            } else {

                logger.info("没有获取到锁，无需释放锁!");

            }

        }

    }

}