Java 독립형 환경에서 예약된 작업을 구현하는 방법

Timed task Framework

TimeTask

TimeTask는 Java를 배우기 시작할 때부터 예약된 작업을 구현하는 데 처음으로 사용되었습니다. Timer는 내부적으로 TaskQueue 클래스를 사용하여 예약된 작업을 저장하는 데 최소 힙 구현을 기준으로 합니다. .레벨 큐. TaskQueue는 작업 간의 거리와 다음 실행 시간에 따라 작업을 정렬하여 힙 상단에 있는 작업이 먼저 실행되도록 합니다.

예제 코드:

 public static void main(String[] args)
    {
          TimerTask task = new TimerTask() {
              public void run() {
                  System.out.println("当前时间: " + new Date() + "n" +
                          "线程名称: " + Thread.currentThread().getName());
              }
          };
          Timer timer = new Timer("Timer");
          long delay = 5000L;
          timer.schedule(task, delay);
          System.out.println("当前时间: " + new Date() + "n" +
                  "线程名称: " + Thread.currentThread().getName());
    }

실행 결과:

当前时间: Wed Apr 06 22:05:04 CST 2022n线程名称: main
当前时间: Wed Apr 06 22:05:09 CST 2022n线程名称: Timer

결과에서 알 수 있듯이 5초 후에 예약된 작업이 실행되었습니다.

단점:

• TimeTask 실행 작업은 순차적으로만 실행할 수 있습니다. 작업 실행 시간이 오래 걸리면 다른 작업 실행에 영향을 미치게 됩니다.

• 작업 실행 중 예외가 발생하면 작업이 바로 중지됩니다.

시간이 지남에 따라 Java 기술은 지속적으로 업데이트되고 있으며 TimeTask의 단점을 보완하기 위해 ScheduledExecutorService가 TimeTask를 대체하는 것처럼 보입니다.

ScheduledExecutorService

ScheduledExecutorService는 여러 구현 클래스가 있는 인터페이스이며, 가장 일반적으로 사용되는 클래스는 ScheduledThreadPoolExecutor입니다. ScheduledThreadPoolExecutor 자체는 DelayQueue를 내부적으로 작업 대기열로 사용하고 작업의 동시 실행을 지원하는 스레드 풀입니다.

예제 코드:

 public static void main(String[] args) throws InterruptedException
   {
      ScheduledExecutorService executorService =
              Executors.newScheduledThreadPool(3);
      // 执行任务: 每 10秒执行一次
      executorService.scheduleAtFixedRate(() -> {
          System.out.println("执行任务：" + new Date()+",线程名称: " + Thread.currentThread().getName());
      }, 1, 10, TimeUnit.SECONDS);
    }

단점:

• jdk의 스레드 풀에서 내부적으로 사용되는 대기열이 상대적으로 크고 OOM이 발생하기 쉽기 때문에 스레드 풀을 생성하기 위해 Executors를 사용하지 마십시오. .

• 예약된 작업은 JVM 독립형 메모리를 기반으로 합니다. 예약된 작업이 다시 시작되면 사라집니다.

• 다양한 예약 작업을 구현하기 위해 cron 표현식을 지원할 수 없습니다.

Spring Task

Spring을 배운 후 Spring 자체의 Task를 사용하기 시작했습니다. Spring Framework는 예약된 작업과 함께 제공되며 다양한 예약된 작업 구성을 구현하기 위한 cron 표현식을 제공합니다.

예제 코드:

@EnableScheduling
@Component
public class SpringTask
{
    private Logger logger = LoggerFactory.getLogger(SpringTask.class);
    private static final SimpleDateFormat dateFormat = new SimpleDateFormat(
            "HH:mm:ss");
    /**
     * fixedRate：固定速率执行。每5秒执行一次。
     */
    @Scheduled(fixedRate = 5000)
    public void invokeTaskWithFixedRate()
    {
        logger.info("Fixed Rate Task :  Current Time  is  {}",
                dateFormat.format(new Date()));
    }
    /**
     * fixedDelay：固定延迟执行。距离上一次调用成功后2秒才执。
     */
    @Scheduled(fixedDelay = 2000)
    public void invokeTaskWithFixedDelay()
    {
        try
        {
            TimeUnit.SECONDS.sleep(3);
            logger.info("Fixed Delay Task : Current Time  is  {}",
                    dateFormat.format(new Date()));
        }
        catch (InterruptedException e)
        {
            logger.error("invoke task error",e);
        }
    }
    /**
     * initialDelay:初始延迟。任务的第一次执行将延迟5秒，然后将以5秒的固定间隔执行。
     */
    @Scheduled(initialDelay = 5000, fixedRate = 5000)
    public void invokeTaskWithInitialDelay()
    {
        logger.info("Task with Initial Delay : Current Time is  {}",
                dateFormat.format(new Date()));
    }
    /**
     * cron：使用Cron表达式,每隔5秒执行一次
     */
    @Scheduled(cron = "0/5 * * * * ? ")
    public void invokeTaskWithCronExpression()
    {
        logger.info("Task Cron Expression:  Current Time  is  {}",
                dateFormat.format(new Date()));
    }
}

실행 결과:

2022-04-06 23:06:20.945 INFO 14604 --- [ 일정-1] com.fw.task.SpringTask : 작업 Cron 식: 현재 시간은 23:06:20
2022-04-06 23:06:22.557 INFO 14604 --- [ 스케줄링-1] com.fw.task.SpringTask : 초기 지연이 있는 작업: 현재 시간은 23:06:22
2022-04-06 23:06:22.557 INFO 14604 --- [ 스케줄링-1] com.fw.task.SpringTask : 고정 비율 태스크 : 현재 시간은 23:06:22
2022-04-06 23:06 :25.955 INFO 14604 --- [ 스케줄링-1] com.fw.task.SpringTask : 고정 지연 태스크 : 현재 시간은 23:06:25
2022-04-06 23:06:25.955 INFO 14604 --- [ 스케줄링 -1] com.fw.task.SpringTask : 작업 Cron 표현식: 현재 시간은 23:06:25
2022-04-06 23:06:27.555 INFO 14604 --- [ 일정-1] com.fw.task. SpringTask : 초기 지연이 있는 작업 : 현재 시간은 23:06:27
2022-04-06 23:06:27.556 INFO 14604 --- [ 일정-1] com.fw.task.SpringTask : 고정 속도 작업 : 현재 시간 is 23:06:27

@EnableScheduling은 예약된 작업을 활성화해야 하며, @Scheduled(cron = "0/5 * * * * ?")는 예약된 작업에 대한 규칙을 구성합니다. cron 표현식은 풍부한 예약 작업 구성을 지원합니다.

장점:

사용이 간단하고 편리하며, 다양하고 복잡한 예약 작업 구성을 지원합니다.

단점:

• 독립 실행형 예약 작업을 기준으로 예약 작업을 다시 시작하면 사라집니다.

• 예약된 작업은 기본적으로 단일 스레드 실행 작업입니다. 병렬 실행이 필요한 경우 @EnableAsync를 켜야 합니다.

• 통일된 그래픽 작업 일정 관리가 없으며 예약된 작업 제어가 불가능합니다

위 내용은 Java 독립형 환경에서 예약된 작업을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!