inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

김영한의 실전 자바 - 고급 1편, 멀티스레드와 동시성

Future4 - 이유

future.get()

260

도토리묵

작성한 질문수 5

0

    public static void main(String[] args) throws InterruptedException, ExecutionException {

        SumTask task1 = new SumTask(1, 50);
        SumTask task2 = new SumTask(51, 100);

        ExecutorService es = Executors.newFixedThreadPool(2);

        Future<Integer> future1 = es.submit(task1);
        Future<Integer> future2 = es.submit(task2);

        log("작업 시작");
        long st = System.currentTimeMillis();
        Integer sum1 = future1.get();

        long end = System.currentTimeMillis();

        log(end - st + "ms");
        Integer sum2 = future2.get();
        log("task1.result = " + sum1);
        log("task2.result = " + sum2);

        int sumAll = sum1 + sum2;
        log("task1 + task2 = " + sumAll);

        es.close();
    }
02:45:32.785 [     main] 작업 시작
02:45:32.785 [pool-1-thread-1] 작업 시작
02:45:32.785 [pool-1-thread-2] 작업 시작
02:45:34.794 [pool-1-thread-1] 작업 완료 result = 1275
02:45:34.794 [pool-1-thread-2] 작업 완료 result = 3775
02:45:34.797 [     main] 2007ms
02:45:34.797 [     main] task1.result = 1275
02:45:34.797 [     main] task2.result = 3775
02:45:34.797 [     main] task1 + task2 = 5050

 

맨 위 코드를 실행했을 때 위와 같은 출력이 나왔습니다.

main 메서드는 BlockingQueue에 등록된 future를 스레드 풀에서 가용 가능한 스레드 만큼 모두 실행 시킨 후에 WAITING 상태로 변경된다고 이해하면 될까요?

java 객체지향 동시성 multithread thread

답변 2

0

dev.rudevico

[스레드풀의 스레드가 작업을 시작하는 시점][get()을 호출하는 시점]이 아니고, [submit()을 호출하는 시점]입니다. 또한 submit()non-blocking method이므로 main 스레드는 스레드 풀에게 작업을 수행해달라는 명령만 전달하고, 본인의 스택에 있는 코드를 이어서 수행할 수 있습니다.

Future<Integer> future1 = es.submit(task1); // pool-1-thread-1 작업 시작. non-blocking
Future<Integer> future2 = es.submit(task2); // pool-1-thread-2 작업 시작. non-blocking

// non-blocking이므로 main에 이어지는 코드들이 계속 수행...
// ...
log(end - st + "ms"); // 마찬가지로 수행됨
Integer sum2 = future2.get();
// ...

0

dev.rudevico

get()"작업을 시작해"가 아니고, "(submit() 이후로) 진행하고 있던 작업을 완료하고, 나에게 그 결과를 리턴해 줘(나는 그때까지 기다리고 있을게)."입니다.

0

나무늘보

안녕하세요. 도토리묵님, 공식 서포터즈 코즈위버입니다.

Executor 에 쓰레드를 submit() 하는 순간 main과 다른 별도의 스레드가 생성됩니다. 그러나 main은 대기상태로 빠지지 않고 계속 다음 코드를 수행하게 됩니다.

단, future1.get(); 코드를 만나는 순간 thread-1 번이 종료될때까지 main 쓰레든느 wait() 상태로 변경됩니다.

질문하신 내용에 답변이 되었는지요? 질문을 조금 더 구체적으로 알려주시면 추가로 답변 드리겠습니다.

감사합니다.

1

도토리묵

제가 생각한 위 코드의 동작 방식을 말씀드리면

  1. future1.get() 을 하면 main 스레드는 wait 상태로 변경, thread-1 실행

  2. thread-1이 종료되면 main 스레드는 runnable 상태로 변경

  3. main 스레드의 log(end - st + "ms"); 실행

  4. future2.get() -> main 스레드는 wait 상태로 변경 -> thread-1이 종료된 경우 thread-1 재사용, 종료되지 않은 경우 thread-2를 사용

위와 같이 생각했지만 출력 로그를 확인한 결과 thread-1, thread-2의 작업이 모두 종료되고, log(end - st + "ms"); 코드가 실행되었습니다.

어떻게 실행시간 로그가 future2.get() 메서드보다 나중에 출력되는지가 궁금합니다!

1

도토리묵

혹시 Executor에 스레드를 submit 하는 순간 스레드 풀에 가용 가능한 스레드가 남아 있을 경우 Callable 구현체의 call 메서드가 바로 실행되나요?

모니터와 synchronized, ReentrantLock, 원자적연산 CAS관련해서 추가적으로 더 깊게 공부했는데 제가 이해한 것이 맞나요??

0

85

1

Future cancel기능을 사용했지만 interrupt가 발생하지 않을 때 어떻게 처리해야하나요?

0

73

2

2.스레드 생성과 실행 - 17P 그림 문의

0

74

2

자바 동시성 현업에서 사용예시가 궁금합니다

0

136

1

ReentrantLock 동작 원리에 대한 질문입니다.

0

84

1

synchronized 대신 join 을 사용하여 순서를 보장할 경우 해법이 아닌가요?

0

94

2

메모리 가시성 문제 질문

0

72

1

Future4-이유 질문

0

64

1

오타 제보

0

77

2

runnable 질문

0

95

2

자바가 아닌 다른 언어에서도

0

112

1

메모리 가시성 문제가 발생하는 이유

0

125

1

데몬스레드가 어떨 때 사용이 되는지 궁금합니다.

0

78

1

Future.cancel() 취소를 사용하는 예가 궁금합니다.

0

84

1

synchronized 와 인스턴스의 lock

0

91

2

synchronized 키워드만으로 메모리 가시성이 해결되는 이유가 궁급합니다.

0

63

1

[스레드 풀과 Executor 프레임워크1][문제와 풀이] `log("일부 작업이 실패했습니다.");` 실행되는 경우가 있을까요?

0

59

1

원자적 연산이 멀티스레드 상황에서 안전한 이유를 제대로 이해했는지 확인 부탁드립니다

0

67

2

자바 고급 1,2,3편 같이 진행해도 문제없나요

0

77

2

CPU 캐시 때문에도 잔액이 200원이 될 수 있나요?

0

105

2

synchronized 메서드와 join 관련 질문이 있습니다.

0

69

2

섹션 14. 115번 강의 내용 질문

0

83

2

교안에 있는 7페이지 데이터 영역

0

51

1

Executor 스레드 풀 관리 질문

0

108

2