파이썬 스레딩 중급 Future 취소와 예외 전파 result와 exception 규칙 정리

🔗 Future 객체와 스레딩의 기본 이해

파이썬의 concurrent.futures 모듈은 스레드풀이나 프로세스풀을 활용해 비동기적으로 작업을 실행할 수 있는 강력한 기능을 제공합니다.
여기서 핵심이 되는 것이 바로 Future 객체인데요.
Future는 아직 완료되지 않은 작업을 표현하며, 완료 상태에 따라 결과를 조회하거나 예외를 확인하고, 필요하다면 취소까지 시도할 수 있습니다.

Future 객체는 크게 대기 상태(pending), 실행 중(running), 완료됨(finished) 상태를 가집니다.
실행이 완료되면 두 가지 경우로 나뉘는데, 정상적으로 결과(result)를 반환하거나, 혹은 예외(exception)를 발생시키는 경우입니다.
따라서 Future는 단순히 “결과를 담는 그릇”이 아니라, 실행의 성공과 실패, 심지어 취소 여부까지 관리하는 중요한 제어 장치라고 할 수 있습니다.

⚡ Future의 주요 메서드 살펴보기

Future 객체는 작업의 상태를 조회하거나 제어하기 위해 여러 메서드를 제공합니다.

• 🛠️cancel() : 실행 전 상태일 경우 작업을 취소
• ⚙️result() : 실행이 끝날 때까지 대기 후 결과 반환 또는 예외 전파
• 🔌exception() : 예외 발생 시 해당 예외 객체 반환, 정상 실행 시 None 반환

이 세 가지 메서드는 서로 긴밀히 연결되어 있습니다.
예를 들어 cancel()이 성공적으로 호출되면 result()를 실행했을 때 CancelledError 예외가 발생합니다.
또한 실행 중 예외가 발생한 경우 result()는 그 예외를 다시 던지지만, exception()은 예외 객체를 그대로 반환하므로 코드 흐름 제어에 따라 선택적으로 활용할 수 있습니다.

🛠️ Future 취소 동작 원리와 주의사항

Future 객체는 실행 전 상태일 때만 cancel() 메서드를 통해 취소가 가능합니다.
이미 실행 중인 작업은 취소 요청을 하더라도 성공하지 않으며, 이 경우 cancel()은 False를 반환합니다.
따라서 취소 기능을 제대로 활용하려면 작업이 시작되기 전에 제어해야 합니다.

취소된 Future는 이후 done() 메서드로 확인했을 때 True를 반환합니다.
그리고 result()를 호출하면 concurrent.futures.CancelledError 예외가 발생합니다.
즉, 취소 여부를 제대로 관리하지 않으면 예상치 못한 예외로 프로그램이 중단될 수 있으므로, 취소 처리 후 예외 흐름까지 고려하는 것이 안전합니다.

⏹️ 취소와 실행 상태의 관계

Future는 pending → running → finished의 흐름을 따릅니다.
이 중 취소가 가능한 시점은 pending 단계뿐이며, running 이후에는 더 이상 취소할 수 없습니다.
즉, cancel()은 “실행 대기열에 올라와 있지만 아직 시작되지 않은 작업”을 건드릴 수 있는 기능입니다.

💬 실행 중인 스레드는 강제로 중단할 수 없으므로, 취소 기능은 항상 작업이 시작되기 전에만 유효하다는 점을 기억하세요.

⚠️ 취소 처리 시 발생할 수 있는 문제

취소를 남용하면 프로그램의 로직이 불안정해질 수 있습니다.
예를 들어, 데이터베이스 업데이트 같은 중요한 작업이 실행 직전에 취소되면 데이터 일관성이 깨질 수 있습니다.
또한, 취소된 Future는 재사용할 수 없으며, 다시 실행하려면 새로운 작업을 제출해야 합니다.

따라서 실무에서는 취소 가능성을 고려하여 취소 시 예외 처리 로직을 반드시 준비해야 하며, 필요한 경우 try-except 구문으로 CancelledError를 잡아내는 습관이 중요합니다.

⚙️ result 메서드 호출 시 동작 규칙

Future 객체의 result() 메서드는 비동기적으로 실행된 작업의 최종 결과를 반환하는 역할을 합니다.
만약 작업이 아직 완료되지 않았다면, 완료될 때까지 호출한 스레드를 블로킹(blocking)합니다.
따라서 result()는 비동기 실행의 결과를 동기적으로 가져오는 다리 역할을 한다고 할 수 있습니다.

result()는 단순히 값만 돌려주는 것이 아니라, 상황에 따라 다양한 동작을 보입니다.
정상적으로 완료된 경우에는 계산된 결과가 반환되지만, 취소되었거나 예외가 발생한 경우에는 예외를 다시 호출자에게 전달합니다.
이 규칙을 이해하는 것이 안전한 동시성 프로그래밍의 핵심입니다.

📌 result() 메서드의 동작 케이스

즉, result()는 단순히 값을 얻는 함수가 아니라 “작업의 성공, 취소, 실패”를 모두 호출자에게 알려주는 메커니즘입니다.
특히 예외 전파 기능 때문에 result()는 try-except 블록과 함께 사용하는 것이 권장됩니다.

from concurrent.futures import ThreadPoolExecutor

def divide(a, b):
    return a / b

with ThreadPoolExecutor() as executor:
    future = executor.submit(divide, 10, 0)
    try:
        print(future.result())  # ZeroDivisionError 예외 발생
    except Exception as e:
        print("예외 발생:", e)

위 예제처럼 result()는 실행 중 발생한 예외를 그대로 전파합니다.
즉, 호출자는 비동기 작업 내부에서 어떤 오류가 일어났는지를 직접 감지하고 대응할 수 있습니다.

🔌 exception 메서드를 통한 예외 전파

Future 객체의 exception() 메서드는 비동기 실행 중 발생한 예외를 직접 확인할 수 있는 방법을 제공합니다.
만약 작업이 정상적으로 완료되었다면 None을 반환하고, 예외가 발생했다면 그 예외 객체를 그대로 돌려줍니다.
즉, exception()은 결과 값이 아닌 “실패 원인”을 확인하는 도구입니다.

이 메서드의 특징은 예외를 “던지지 않는다”는 점입니다.
즉, result()와 달리 exception()은 호출자에게 예외를 발생시키지 않고, 단순히 반환값으로 알려줍니다.
이를 통해 예외가 발생했는지 여부를 안전하게 점검할 수 있으며, 상황에 따라 후속 로직을 유연하게 처리할 수 있습니다.

🧩 exception() 활용 시나리오

exception()은 주로 다음과 같은 경우에 활용됩니다.

• 🛠️여러 Future 객체 중 어떤 작업에서 예외가 발생했는지 식별할 때
• ⚙️예외 발생 여부만 체크하고, 실제 예외 전파는 원하지 않을 때
• 🔌로그 기록이나 모니터링 시스템에 예외 정보를 저장할 때

from concurrent.futures import ThreadPoolExecutor

def faulty_task():
    raise ValueError("문제 발생!")

with ThreadPoolExecutor() as executor:
    future = executor.submit(faulty_task)
    ex = future.exception()
    if ex:
        print("예외 확인:", ex)  # 예외 객체를 직접 반환

위 코드에서 exception()은 발생한 ValueError 객체를 반환하며, 호출자는 이를 활용해 추가적인 처리(예: 로그 남기기, 다른 대체 동작 수행 등)를 할 수 있습니다.

💡 result와 exception의 차이점 비교

Future 객체의 result()와 exception() 메서드는 모두 비동기 작업의 완료 상태를 확인하는 데 사용되지만, 동작 방식과 반환 값에는 중요한 차이가 있습니다.
이 차이를 이해하면 코드의 안정성과 가독성을 크게 높일 수 있습니다.

🔍 result() vs exception() 비교표

즉, result()는 “값을 직접 가져오는” 방식이고, exception()은 “실패 원인을 안전하게 확인하는” 방식이라고 이해할 수 있습니다.
상황에 따라 적절히 선택해야 하며, 두 메서드를 함께 사용하는 것도 좋은 패턴입니다.

📝 활용 팁

실무에서는 다음과 같은 접근이 권장됩니다.

• ⚙️정상 결과가 필요하다면 result() 사용
• 🛠️예외 발생 여부만 체크하려면 exception() 사용
• 🔌대규모 스레드풀에서 여러 Future를 모니터링할 때는 exception()으로 우선 예외 여부를 확인한 뒤, 필요 시 result() 호출

❓ 자주 묻는 질문 (FAQ)