만약 어떤 작업을 일정 시간 지연 후에 수행하거나, 일정 시간 간격으로 주기적으로 실행해야 한다면, ScheduledThreadPoolExecutor를 고려해보는 것이 좋습니다.
ScheduledThreadPoolExecutor 다음 4개의 메소드들을 제공합니다.
- schedule(Runnable command, long delay, TimeUnit unit) : 작업을 일정 시간 뒤에 한번 실행합니다.
- schedule(Callable
command, long delay, TimeUnit unit) : 작업을 일정 시간 뒤에 한번 실행하고, 그 결과를 리턴합니다. - scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) : 작업을 일정 시간 간격으로 반복적으로 실행시킵니다.
- scheduleWithFixedDelay(Runnable command, long initialDelay, long period, TimeUnit unit) : 작업이 완료되면 일정 시간 뒤에 다시 실행시킵니다. scheduleAtFixedRate()와 다른 점은 작업 종료시점이 기준이라는 것입니다.
schedule(Runnable)
schedule()은 일정 시간(delay) 뒤에 Job을 실행시키는 메소드입니다.
schedule()에 전달되는 인자는 다음과 같습니다.
- Runnable : 리턴 값이 없는 Runnable을 인자로 받습니다.
- delay : 지연 시킬 시간입니다.
- TimeUnit : 시간 단위입니다.
package concurrent;
import java.time.LocalTime;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledThreadPoolExecutorExample1 {
public static void main(String[] args) {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
Runnable runnable = () -> System.out.println("Runnable task : " + LocalTime.now());
int delay = 3;
// Job을 스케쥴링합니다.
System.out.println("Scheduled task : " + LocalTime.now() );
executor.schedule(runnable, delay, TimeUnit.SECONDS);
}
}
결과
Scheduled task : 22:58:43.006
Runnable task : 22:58:46.007
schedule(Callable)
schedule()은 일정 시간 뒤에 Job을 실행시키는 메소드입니다.
schedule()에 전달되는 인자는 다음과 같습니다.
- Callable
: T를 리턴하는 Callable 인자로 받습니다. - delay : 지연 시킬 시간입니다.
- TimeUnit : 시간 단위입니다.
schedule()은 ScheduledFuture<T>를 리턴하며 Job이 완료되면 ScheduledFuture.get()으로 리턴값을 얻을 수 있습니다.
package concurrent;
import java.time.LocalTime;
import java.util.concurrent.*;
public class ScheduledThreadPoolExecutorExample2 {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
Callable<String> callable = () -> "Callable task : " + LocalTime.now();
int delay = 3;
// Job을 스케쥴링합니다.
System.out.println("Scheduled task : " + LocalTime.now() );
ScheduledFuture<String> future =
executor.schedule(callable, delay, TimeUnit.SECONDS);
// 결과가 리턴될 때 까지 기다립니다.
String result = future.get();
System.out.println(result);
}
}
결과
Scheduled task : 23:00:00.025
Callable task : 23:00:03.027
scheduleAtFixedRate()
scheduleAtFixedRate()는 작업을 일정 시간 간격으로 실행시키는 메소드입니다.
scheduleAtFixedRate()에 전달되는 인자는 다음과 같습니다.
- Runnable : 리턴 값이 없는 Runnable을 인자로 받습니다.
- initialDelay : Job이 처음 실행될 때 기다리는 시간입니다.
- delay : Job이 실행되는 시간 간격입니다.
- TimeUnit : 시간 단위입니다.
다음 예제의 결과를 보시면 Job이 실행된 후(완료되는 시간과 무관하게), 일정 delay 뒤에 다시 Job을 실행시키는 것을 볼 수 있습니다.
package concurrent;
import java.time.LocalTime;
import java.util.concurrent.*;
public class ScheduledThreadPoolExecutorExample3 {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
Runnable runnable = () -> {
System.out.println("++ Repeat task : " + LocalTime.now());
sleepSec(3);
System.out.println("-- Repeat task : " + LocalTime.now());
};
int initialDelay = 2;
int delay = 3;
// Job을 스케쥴링합니다.
System.out.println("Scheduled task : " + LocalTime.now() );
executor.scheduleAtFixedRate(
runnable, initialDelay, delay, TimeUnit.SECONDS);
}
private static void sleepSec(int sec) {
try {
TimeUnit.SECONDS.sleep(sec);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
결과
Scheduled task : 23:01:48.967
++ Repeat task : 23:01:50.969
-- Repeat task : 23:01:53.969
++ Repeat task : 23:01:53.970
-- Repeat task : 23:01:56.970
++ Repeat task : 23:01:56.971
-- Repeat task : 23:01:59.971
++ Repeat task : 23:01:59.971
-- Repeat task : 23:02:02.972
++ Repeat task : 23:02:02.972
-- Repeat task : 23:02:05.972
++ Repeat task : 23:02:05.973
-- Repeat task : 23:02:08.973
....
scheduleWithFixedDelay()
scheduleAtFixedRate()는 Job이 완료된 후, 일정 시간 뒤에 다시 Job을 실행시키는 메소드입니다.
scheduleWithFixedDelay()에 전달되는 인자는 다음과 같습니다.
- Runnable : 리턴 값이 없는 Runnable을 인자로 받습니다.
- initialDelay : Job이 처음 실행될 때 기다리는 시간입니다.
- delay : Job이 완료된 후 다음 Job이 실행될 때까지 기다리는 시간입니다.
- TimeUnit : 시간 단위입니다.
다음 예제의 결과를 보시면 Job이 끝난 후, delay만큼 기다린 후 다음 Job을 실행시키는 것을 볼 수 있습니다.
package concurrent;
import java.time.LocalTime;
import java.util.concurrent.*;
public class ScheduledThreadPoolExecutorExample4 {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
Runnable runnable = () -> {
System.out.println("++ Repeat task : " + LocalTime.now());
sleepSec(3);
System.out.println("-- Repeat task : " + LocalTime.now());
};
int initialDelay = 2;
int delay = 3;
// Job을 스케쥴링합니다.
System.out.println("Scheduled task : " + LocalTime.now() );
executor.scheduleWithFixedDelay(
runnable, initialDelay , delay, TimeUnit.SECONDS);
}
private static void sleepSec(int sec) {
try {
TimeUnit.SECONDS.sleep(sec);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
결과
Scheduled task : 23:03:29.282
++ Repeat task : 23:03:31.284
-- Repeat task : 23:03:34.285
++ Repeat task : 23:03:37.285
-- Repeat task : 23:03:40.286
++ Repeat task : 23:03:43.286
-- Repeat task : 23:03:46.286
++ Repeat task : 23:03:49.287
-- Repeat task : 23:03:52.287
++ Repeat task : 23:03:55.288
-- Repeat task : 23:03:58.288
++ Repeat task : 23:04:01.288
-- Repeat task : 23:04:04.289
....
Loading script...
Related Posts
- Java - Unsupported class file major version 61 에러
- Java - String.matches()로 문자열 패턴 확인 및 다양한 예제 소개
- Java - 문자열 공백제거 (trim, replace)
- Java - replace()와 replaceAll()의 차이점
- Java - ArrayList 초기화, 4가지 방법
- Java - 배열 정렬(Sorting) (오름차순, 내림차순)
- Java - 문자열(String)을 비교하는 방법 (==, equals, compare)
- Java - StringBuilder 사용 방법, 예제
- Java - 로그 출력, 파일 저장 방법 (Logger 라이브러리)
- Java IllegalArgumentException 의미, 발생 이유
- Java - NullPointerException 원인, 해결 방법
- Seleninum의 ConnectionFailedException: Unable to establish websocket connection 해결
- Java - compareTo(), 객체 크기 비교
- Java - BufferedWriter로 파일 쓰기
- Java - BufferedReader로 파일 읽기
- Java charAt() 함수 알아보기
- Java - BigInteger 범위, 비교, 연산, 형변환
- Java contains()로 문자(대소문자 X) 포함 확인
- Java - Set(HashSet)를 배열로 변환
- Java - 문자열 첫번째 문자, 마지막 문자 확인
- Java - 문자열 한글자씩 자르기
- Java - 문자열 단어 개수 가져오기
- Java - 1초마다 반복 실행
- Java - 배열을 Set(HashSet)로 변환
- Java - 여러 Set(HashSet) 합치기
- Java - 명령행 인자 입력 받기
- Java - 리스트 역순으로 순회, 3가지 방법
- Java - 특정 조건으로 리스트 필터링, 3가지 방법
- Java - HashMap 모든 요소들의 합계, 평균 계산
- Java - 특정 조건으로 HashMap 필터링
- Java - 싱글톤(Singleton) 패턴 구현
- Java - 숫자 왼쪽에 0으로 채우기
- Java - String 배열 초기화 방법
- Java - 정렬된 순서로 Map(HashMap) 순회
- Java - HashMap에서 key, value 가져오기