인프런 커뮤니티 질문&답변

[비교 결론]

(맥북 프로 2018형 기준)

• yield() 사용 X: 체크 로직 319_216_379회 수행

• yield() 사용 O: 체크 로직 000_730_447회 수행

[코드 사용법]

• 체크로직 while loop에 있는 Thread.yield();를 주석처리 on/off 하면서 체크하시면 됩니다.

• 프로그램 수행 -> a, b, c, d, e, q를 순서대로 입력

• 위 두 동작을 주석처리 on/off한 후에 실행하는 두 경우 모두에서 비슷한 속도로 해 주시면 비교가 더 명확합니다.

[코드 설명]

MyPrinterV4 코드를 기준으로 하여 다음과 같이 체크 로직의 수행 횟수를 카운트할 수 있도록 개선했습니다. 러프하게 작성한 코드라서 세부적인 부분은 무시바랍니다.

// 체크 로직의 수행 횟수를 기록하는 변수
private static int count = 0;

while (!Thread.interrupted()) {
    if (jobQueue.isEmpty()) {
        count++; // 체크 로직 수행시 1회 추가 기록
        Thread.yield(); // 여기를 On/Off하며 체크
        continue;
    }
}

// 메인 함수의 마지막 부분에 추가한 코드
// q를 입력하여 프로그램을 종료했을 때까지 수행된 체크 로직의 횟수를 출력
System.out.println(count);

[전체 코드]

package thread.control.printer;

import java.util.Queue;
import java.util.Scanner;
import java.util.concurrent.ConcurrentLinkedQueue;

import static util.MyLogger.log;

public class MyPrinterV4 {

    // 추가된 코드
    private static int count = 0;

    public static void main(String[] args) {
        Printer printer = new Printer();
        Thread printerThread = new Thread(printer, "printer");
        printerThread.start();

        Scanner userInput = new Scanner(System.in);
        while (true) {
            log("프린터할 문서를 입력하세요. 종료 (q): ");
            String input = userInput.nextLine();
            if (input.equals("q")) {
                printerThread.interrupt(); 
                break;
            }

            printer.addJob(input);
        }
        // 추가된 코드
        System.out.println(count);

    }

    static class Printer implements Runnable {

        Queue<String> jobQueue = new ConcurrentLinkedQueue<>();

        @Override
        public void run() {

            while (!Thread.interrupted()) {
                if (jobQueue.isEmpty()) {
                    // 코드 추가된 부분(시작)
                    count++;
                    Thread.yield(); // 주석 on/off 하며 비교
                    // 코드 추가된 부분(종료)
                    continue;
                }

                try {
                    String job = jobQueue.poll();
                    log("출력 시작: " + job + ", 대기 문서: " + jobQueue);
                    Thread.sleep(3000);
                    log("출력 완료: " + job);
                } catch (InterruptedException e) {
                    log("인터럽트 발생. message=" + e.getMessage());
                    break;
                }
            }
            log("프린터 종료");
        }

        public void addJob(String input) {
            jobQueue.offer(input);
        }
    }
}