packaged_task와 async 중 어떤 걸 쓰나요?

packaged_task는 작업 객체를 재사용·이동해 스레드 풀에 넣기 좋습니다. async는 간단한 일회성 작업에 편합니다.

예외가 future에 어떻게 전달되나요?

작업 안에서 던진 예외가 future::get에서 재던져집니다. 소비하지 않으면 std::future 소멸 시 정책에 따라 terminate될 수 있어 주의하세요.

여러 번 결과를 받을 수 있나요?

packaged_task는 한 번만 실행됩니다. 공유 소비가 필요하면 shared_future나 결과를 복사 가능한 값으로 설계하세요.

스레드 풀과 함께 쓸 때 주의점은?

작업이 큐에 머무는 동안 캡처한 자원 수명을 보장해야 합니다. promise/future 쌍의 소유권을 명확히 하세요.

C++ packaged_task | '패키지 태스크' 가이드

2026년 3월 12일 · 14분 읽기 · 수정 2026년 3월 30일 중급 튜토리얼

이 글의 핵심

std::packaged_task 는 함수나 호출 가능 객체를 래핑하여 std::future로 결과를 받을 수 있게 하는 C++11 기능입니다. std::async와 달리 수동으로 실행 시점을 제어할 수 있어, 작업 큐나 스레드 풀에서 유용합니다.

packaged_task란?

std::packaged_task 는 함수나 호출 가능 객체를 래핑하여 std::future로 결과를 받을 수 있게 하는 C++11 기능입니다. std::async와 달리 수동으로 실행 시점을 제어할 수 있어, 작업 큐나 스레드 풀에서 유용합니다.

#include <future>

std::packaged_task<int(int)> task([](int x) {
    return x * x;
});

std::future<int> future = task.get_future();
task(10);  // 실행

int result = future.get();  // 100

왜 필요한가?:

실행 제어: 언제 실행할지 직접 결정
작업 큐: 작업을 큐에 저장 후 나중에 실행
스레드 풀: 워커 스레드에 작업 분배
예외 전파: 예외를 future로 전달

// std::async: 즉시 실행 (또는 지연)
auto f1 = std::async([] { return 42; });

// packaged_task: 수동 실행
std::packaged_task<int()> task([] { return 42; });
auto f2 = task.get_future();
// 원하는 시점에 실행
task();

기본 사용

C/C++ 예제 코드입니다.

// 함수 시그니처 지정
std::packaged_task<int(int, int)> task([](int a, int b) {
    return a + b;
});

auto future = task.get_future();
task(3, 4);  // 실행
int result = future.get();  // 7

실전 예시

예시 1: 스레드에서 실행

compute 함수의 구현 예제입니다.

#include <thread>
#include <future>

int compute(int x) {
    std::this_thread::sleep_for(std::chrono::seconds(1));
    return x * x;
}

int main() {
    std::packaged_task<int(int)> task(compute);
    std::future<int> future = task.get_future();
    
    std::thread t(std::move(task), 10);
    
    std::cout << "계산 중..." << std::endl;
    int result = future.get();
    std::cout << "결과: " << result << std::endl;
    
    t.join();
}

예시 2: 작업 큐

#include <queue>
#include <mutex>

class TaskQueue {
    std::queue<std::packaged_task<void()>> tasks;
    std::mutex mtx;
    
public:
    template<typename F>
    auto enqueue(F&& f) -> std::future<decltype(f())> {
        using ReturnType = decltype(f());
        
        std::packaged_task<ReturnType()> task(std::forward<F>(f));
        auto future = task.get_future();
        
        {
            std::lock_guard<std::mutex> lock(mtx);
            tasks.push(std::move(task));
        }
        
        return future;
    }
    
    void process() {
        std::packaged_task<void()> task;
        
        {
            std::lock_guard<std::mutex> lock(mtx);
            if (tasks.empty()) return;
            
            task = std::move(tasks.front());
            tasks.pop();
        }
        
        task();
    }
};

예시 3: 예외 처리

std::packaged_task<int()> task([] {
    throw std::runtime_error("에러");
    return 42;
});

auto future = task.get_future();
task();

try {
    int result = future.get();  // 예외 재던지기
} catch (const std::exception& e) {
    std::cout << "예외: " << e.what() << std::endl;
}

예시 4: 재사용

C/C++ 예제 코드입니다.

std::packaged_task<int(int)> task([](int x) {
    return x * 2;
});

auto f1 = task.get_future();
task(10);
int r1 = f1.get();  // 20

// ❌ 재사용 불가
// task(20);  // 에러

// ✅ 새로 생성
task = std::packaged_task<int(int)>([](int x) {
    return x * 2;
});

async vs packaged_task

// std::async: 자동 실행
auto f1 = std::async([] { return 42; });

// packaged_task: 수동 실행
std::packaged_task<int()> task([] { return 42; });
auto f2 = task.get_future();
task();  // 명시적 실행

비교표:

특징	std::async	std::packaged_task
실행 시점	자동 (즉시 또는 지연)	수동 (명시적 호출)
스레드 생성	자동	수동
사용 편의성	간단	복잡
제어 수준	낮음	높음
주 용도	간단한 비동기 작업	작업 큐, 스레드 풀

실무 선택 가이드:

int expensiveComputation();  // 어딘가에 정의되어 있다고 가정

// ✅ std::async 사용
// - 간단한 비동기 작업
// - 스레드 관리 불필요
auto result = std::async([] {
    return expensiveComputation();
});

// ✅ packaged_task 사용
// - 작업 큐에 저장
// - 실행 시점 제어
// - 스레드 풀 구현
std::packaged_task<int()> task(expensiveComputation);
taskQueue.push(std::move(task));
// 나중에 워커 스레드가 실행

자주 발생하는 문제

문제 1: 실행 누락

C/C++ 예제 코드입니다.

std::packaged_task<int()> task([] { return 42; });
auto future = task.get_future();

// ❌ task 실행 안함
// int result = future.get();  // 영원히 대기

// ✅ task 실행
task();
int result = future.get();

문제 2: 이동 전용

C/C++ 예제 코드입니다.

std::packaged_task<int()> task([] { return 42; });

// ❌ 복사 불가
// auto task2 = task;

// ✅ 이동
auto task2 = std::move(task);

문제 3: get_future 여러 번

std::packaged_task<int()> task([] { return 42; });

auto f1 = task.get_future();
// auto f2 = task.get_future();  // 에러

// get_future는 한 번만

문제 4: 스레드 이동

C/C++ 예제 코드입니다.

std::packaged_task<int()> task([] { return 42; });
auto future = task.get_future();

// ✅ 이동으로 전달
std::thread t(std::move(task));
t.join();

int result = future.get();

실무 패턴

패턴 1: 간단한 스레드 풀

#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <future>

class ThreadPool {
    std::vector<std::thread> workers_;
    std::queue<std::packaged_task<void()>> tasks_;
    std::mutex mtx_;
    std::condition_variable cv_;
    bool stop_ = false;
    
public:
    ThreadPool(size_t numThreads) {
        for (size_t i = 0; i < numThreads; ++i) {
            workers_.emplace_back([this]() {
                while (true) {
                    std::packaged_task<void()> task;
                    
                    {
                        std::unique_lock<std::mutex> lock(mtx_);
                        cv_.wait(lock, [this]() { 
                            return stop_ || !tasks_.empty(); 
                        });
                        
                        if (stop_ && tasks_.empty()) return;
                        
                        task = std::move(tasks_.front());
                        tasks_.pop();
                    }
                    
                    task();
                }
            });
        }
    }
    
    template<typename F>
    auto submit(F&& f) -> std::future<decltype(f())> {
        using ReturnType = decltype(f());
        
        std::packaged_task<ReturnType()> task(std::forward<F>(f));
        auto future = task.get_future();
        
        {
            std::lock_guard<std::mutex> lock(mtx_);
            tasks_.push(std::move(task));
        }
        
        cv_.notify_one();
        return future;
    }
    
    ~ThreadPool() {
        {
            std::lock_guard<std::mutex> lock(mtx_);
            stop_ = true;
        }
        cv_.notify_all();
        for (auto& worker : workers_) {
            worker.join();
        }
    }
};

// 사용
ThreadPool pool(4);
auto f1 = pool.submit([] { return 42; });
auto f2 = pool.submit([] { return 100; });

std::cout << f1.get() + f2.get() << '\n';  // 142

패턴 2: 타임아웃 작업

runWithTimeout 함수의 구현 예제입니다.

template<typename F>
auto runWithTimeout(F&& f, std::chrono::milliseconds timeout) 
    -> std::optional<decltype(f())> {
    
    std::packaged_task<decltype(f())()> task(std::forward<F>(f));
    auto future = task.get_future();
    
    std::thread t(std::move(task));
    t.detach();
    
    if (future.wait_for(timeout) == std::future_status::ready) {
        return future.get();
    }
    
    return std::nullopt;  // 타임아웃
}

// 사용
auto result = runWithTimeout([] {
    std::this_thread::sleep_for(std::chrono::seconds(2));
    return 42;
}, std::chrono::seconds(1));

if (result) {
    std::cout << "결과: " << *result << '\n';
} else {
    std::cout << "타임아웃\n";
}

패턴 3: 작업 취소

class CancellableTask {
    std::packaged_task<int()> task_;
    std::atomic<bool> cancelled_{false};
    
public:
    CancellableTask(std::function<int()> f) 
        : task_([this, f]() {
            if (cancelled_) {
                throw std::runtime_error("Cancelled");
            }
            return f();
        }) {}
    
    std::future<int> getFuture() {
        return task_.get_future();
    }
    
    void run() {
        task_();
    }
    
    void cancel() {
        cancelled_ = true;
    }
};

`std::promise` / `std::future`와의 관계

비동기 결과를 연결하는 표준 구성은 크게 세 가지입니다.

구성 요소	역할
std::promise	수동으로 값/예외를 `future` 쪽에 설정 (`set_value`, `set_exception`)
std::packaged_task	호출 가능 객체 한 번 실행의 결과를 자동으로 연결된 `future`에 기록
std::async	함수 실행과 스레딩 정책을 묶은 편의 API (구현에 따라 스레드 풀 재사용 여부는 비표준)

packaged_task는 내부적으로 공유 상태를 두고 get_future()로 소비자 쪽 future를 내줍니다. 반면 promise는 생산자가 직접 “아직 계산 중”인 값을 채워 넣을 때 쓰입니다. 작업 큐에서는 “실행 본체”를 packaged_task로 감싸 두면, 워커가 operator()만 호출하면 되므로 연결 코드가 짧아집니다.

비동기 작업 패턴 정리

fire-and-forget: 결과가 필요 없으면 std::thread + 조인 정책만 정하고 끝낼 수 있지만, 예외 전파가 어렵습니다. 결과·오류를 상위로 올리려면 packaged_task/async/promise 중 하나를 씁니다.
결과 필수: future.get() 한 번으로 값 또는 예외를 받습니다. 여러 번 구독하려면 shared_future를 고려합니다.
백프레셔·큐 길이 제한: 생산자가 submit만 하고 소비가 못 따라가면 메모리가 불어납니다. 큐 상한, 블로킹 큐, 또는 거부 정책을 함께 설계합니다.

실전 예제 보강: 에러 처리 전략

future.get(): 작업 안에서 던진 예외는 저장되었다가 get() 시점에 재던집니다. 따라서 호출 스레드에서 try/catch를 두는 것이 일반적입니다.
타임아웃: wait_for / wait_until로 무한 대기를 피하고, 실패 시 로깅·재시도·취소 플래그를 택합니다. 위 runWithTimeout은 데모이며, 실제로는 취소 협력(주기적 플래그 확인)이 없으면 스레드가 계속 돌 수 있어 프로덕션에서는 주의가 필요합니다.
std::current_exception: 저수준에서 promise에 예외를 넣을 때 유용하지만, 대부분은 packaged_task가 자동 처리하면 충분합니다.

std::packaged_task<int()> task([] {
    if (!validateInput()) {
        throw std::invalid_argument("bad input");
    }
    return compute();
});
auto fut = task.get_future();
std::thread(std::move(task)).detach();

try {
    use(fut.get());
} catch (const std::exception& e) {
    log_error(e.what());
}

FAQ

Q1: packaged_task는 무엇인가요?

A: 함수나 호출 가능 객체를 래핑하여 std::future로 결과를 받을 수 있게 하는 클래스입니다. 수동으로 실행 시점을 제어할 수 있습니다.

Q2: std::async와 차이는?

std::async: 자동 실행 (즉시 또는 지연), 스레드 자동 생성
packaged_task: 수동 실행, 스레드 수동 생성

// async: 간단
auto f = std::async(compute);

// packaged_task: 제어
std::packaged_task<int()> task(compute);
auto f = task.get_future();
std::thread t(std::move(task));
t.join();

Q3: packaged_task를 재사용할 수 있나요?

A: 불가능합니다. 한 번 실행하면 새로 생성해야 합니다.

C/C++ 예제 코드입니다.

std::packaged_task<int()> task([] { return 42; });
task();
// task();  // 에러

// 새로 생성
task = std::packaged_task<int()>([] { return 42; });

Q4: packaged_task는 복사할 수 있나요?

A: 불가능합니다. 이동만 가능합니다.

std::packaged_task<int()> task1([] { return 42; });
// auto task2 = task1;  // 에러
auto task2 = std::move(task1);  // OK

Q5: 언제 사용해야 하나요?

작업 큐 구현
스레드 풀 구현
실행 시점을 직접 제어해야 할 때
작업을 저장 후 나중에 실행해야 할 때

Q6: get_future()를 여러 번 호출할 수 있나요?

A: 불가능합니다. get_future()는 한 번만 호출할 수 있습니다.

std::packaged_task<int()> task([] { return 42; });
auto f1 = task.get_future();
// auto f2 = task.get_future();  // 에러

Q7: 예외는 어떻게 처리되나요?

A: 작업 실행 중 발생한 예외는 future에 저장되며, future.get() 호출 시 재던져집니다.

std::packaged_task<int()> task([] {
    throw std::runtime_error("Error");
    return 42;
});

auto f = task.get_future();
task();

try {
    f.get();  // 예외 재던지기
} catch (const std::exception& e) {
    std::cout << e.what() << '\n';
}

Q8: packaged_task 학습 리소스는?

“C++ Concurrency in Action” by Anthony Williams
“Effective Modern C++” by Scott Meyers
cppreference.com - std::packaged_task

관련 글: std::future, std::async, std::promise.

한 줄 요약: packaged_task는 함수를 래핑하여 future로 결과를 받을 수 있게 하며, 수동 실행 제어가 가능합니다.

같이 보면 좋은 글 (내부 링크)

이 주제와 연결되는 다른 글입니다.

심화 부록: 구현·운영 관점

이 부록은 앞선 본문에서 다룬 주제(「C++ packaged_task | ‘패키지 태스크’ 가이드」)를 구현·런타임·운영 관점에서 다시 압축합니다. 도메인별 세부 구현은 글마다 다르지만, 입력 검증 → 핵심 연산 → 부작용(I/O·네트워크·동시성) → 관측의 흐름으로 장애를 나누면 원인 추적이 빨라집니다.

내부 동작과 핵심 메커니즘

flowchart TD
  A[입력·요청·이벤트] --> B[파싱·검증·디코딩]
  B --> C[핵심 연산·상태 전이]
  C --> D[부작용: I/O·네트워크·동시성]
  D --> E[결과·관측·저장]

sequenceDiagram
  participant C as 클라이언트/호출자
  participant B as 경계(런타임·게이트웨이·프로세스)
  participant D as 의존성(API·DB·큐·파일)
  C->>B: 요청/이벤트
  B->>D: 조회·쓰기·RPC
  D-->>B: 지연·부분 실패·재시도 가능
  B-->>C: 응답 또는 오류(코드·상관 ID)

불변 조건(Invariant): 버퍼 경계, 프로토콜 상태, 트랜잭션 격리, FD 상한 등 단계별로 문장으로 적어 두면 디버깅 비용이 줄어듭니다.
결정성: 순수 층과 시간·네트워크·스케줄에 의존하는 층을 분리해야 테스트와 장애 분석이 쉬워집니다.
경계 비용: 직렬화, 인코딩, syscall 횟수, 락 경합, 할당·GC, 캐시 미스를 의심 목록에 둡니다.
백프레셔: 생산자가 소비자보다 빠를 때 버퍼·큐·스트림에서 속도를 줄이는 신호를 어디에 둘지 정의합니다.

프로덕션 운영 패턴

영역	운영 관점 질문
관측성	요청 단위 상관 ID, 에러율·지연 p95/p99, 의존성 타임아웃·재시도가 대시보드에 보이는가
안전성	입력 검증·권한·비밀·감사 로그가 코드 경로마다 일관적인가
신뢰성	재시도는 멱등 연산에만 적용되는가, 서킷 브레이커·백오프·DLQ가 있는가
성능	캐시·배치 크기·커넥션 풀·인덱스·백프레셔가 데이터 규모에 맞는가
배포	롤백 룬북, 카나리/블루그린, 마이그레이션·피처 플래그가 문서화되어 있는가
용량	피크 트래픽·디스크·FD·스레드 풀 상한을 주기적으로 검증하는가

스테이징은 데이터 양·네트워크 RTT·동시성을 프로덕션에 가깝게 맞출수록 재현율이 올라갑니다.

확장 예시: 엔드투엔드 미니 시나리오

앞선 본문 주제(「C++ packaged_task | ‘패키지 태스크’ 가이드」)를 배포·운영 흐름에 맞춰 옮긴 체크리스트입니다. 도메인에 맞게 단계 이름만 바꿔 적용할 수 있습니다.

입력 계약 고정: 스키마·버전·최대 페이로드·타임아웃·에러 코드를 경계에 둔다.
핵심 경로 계측: 요청 ID, 단계별 지연, 외부 호출 결과 코드를 로그·메트릭·트레이스에서 한 흐름으로 본다.
실패 주입: 의존성 타임아웃·5xx·부분 데이터·락 대기를 스테이징에서 재현한다.
호환·롤백: 설정/마이그레이션/클라이언트 버전을 되돌릴 수 있는지 확인한다.
부하 후 검증: 피크 대비 p95/p99, 에러율, 리소스 상한, 알림 임계값을 점검한다.

handle(request):
  ctx = newCorrelationId()
  validated = validateSchema(request)
  authorize(validated, ctx)
  result = domainCore(validated)
  persistOrEmit(result, idempotentKey)
  recordMetrics(ctx, latency, outcome)
  return result

문제 해결(Troubleshooting)

증상	가능 원인	조치
간헐적 실패	레이스, 타임아웃, 외부 의존성, DNS	최소 재현 스크립트, 분산 트레이스·로그 상관관계, 재시도·서킷 설정 점검
성능 저하	N+1, 동기 I/O, 락 경합, 과도한 직렬화, 캐시 미스	프로파일러·APM으로 핫스팟 확인 후 한 가지씩 제거
메모리 증가	캐시 무제한, 구독/리스너 누수, 대용량 버퍼, 커넥션 미반납	상한·TTL·힙/FD 스냅샷 비교
빌드·배포만 실패	환경 변수, 권한, 플랫폼 차이, lockfile	CI 로그와 로컬 diff, 런타임·이미지 버전 핀
설정 불일치	프로필·시크릿·기본값, 리전	스키마 검증된 설정 단일 소스와 배포 매트릭스 표준화
데이터 불일치	비멱등 재시도, 부분 쓰기, 캐시 무효화 누락	멱등 키·아웃박스·트랜잭션 경계 재검토

권장 순서: (1) 최소 재현 (2) 최근 변경 범위 축소 (3) 환경·의존성 차이 (4) 관측으로 가설 검증 (5) 수정 후 회귀·부하 테스트.

배포 전에는 git add → git commit → git push 후 npm run deploy 순서를 권장합니다.

이 글에서 다루는 키워드 (관련 검색어)

C++, packaged_task, future, async, C++11 등으로 검색하시면 이 글이 도움이 됩니다.

이 글이 도움이 되셨나요?

여러분의 피드백은 더 나은 콘텐츠를 만드는 데 도움이 됩니다

문제가 있거나 개선 제안이 있으시면 연락처로 알려주세요.

Keyboard Shortcuts

이 글의 핵심

packaged_task란?

기본 사용

실전 예시

예시 1: 스레드에서 실행

예시 2: 작업 큐

예시 3: 예외 처리

예시 4: 재사용

async vs packaged_task

자주 발생하는 문제

문제 1: 실행 누락

문제 2: 이동 전용

문제 3: get_future 여러 번

문제 4: 스레드 이동

실무 패턴

패턴 1: 간단한 스레드 풀

패턴 2: 타임아웃 작업

패턴 3: 작업 취소

std::promise / std::future와의 관계

비동기 작업 패턴 정리

실전 예제 보강: 에러 처리 전략

FAQ

Q1: packaged_task는 무엇인가요?

Q2: std::async와 차이는?

Q3: packaged_task를 재사용할 수 있나요?

Q4: packaged_task는 복사할 수 있나요?

Q5: 언제 사용해야 하나요?

Q6: get_future()를 여러 번 호출할 수 있나요?

Q7: 예외는 어떻게 처리되나요?

Q8: packaged_task 학습 리소스는?

같이 보면 좋은 글 (내부 링크)

관련 글

심화 부록: 구현·운영 관점

내부 동작과 핵심 메커니즘

프로덕션 운영 패턴

확장 예시: 엔드투엔드 미니 시나리오

문제 해결(Troubleshooting)

이 글에서 다루는 키워드 (관련 검색어)

이 글이 도움이 되셨나요?

`std::promise` / `std::future`와의 관계