thread_try_lock

thread_try_lock (여러 Lockable 객체를 잠그기)

std::try_lock은 여러 Lockable 객체를 순서대로 잠그려고 시도하는 함수 템플릿이에요. 첫 번째 객체부터 차례로 try_lock을 호출하다가 실패하면 이미 잠근 객체를 모두 해제하고 실패한 객체의 인덱스를 반환해요. 이 함수는 여러 뮤텍스를 한 번에 안전하게 다루고 싶을 때 유용해요.

출처: cppreference

본문

정의

<mutex> 헤더에 정의되어 있어요.

동작

주어진 Lockable 객체 lock1, lock2, ..., lockn을 첫 번째부터 순서대로 try_lock을 호출하면서 잠그려고 시도해요.

try_lock 호출이 실패하면 더 이상의 try_lock 호출은 수행되지 않고, 이미 잠긴 객체들에 대해 unlock을 호출한 뒤 실패한 객체의 0부터 시작하는 인덱스를 반환해요.

try_lock 호출 중 예외가 발생하면, 예외를 다시 던지기 전에 이미 잠긴 객체들에 대해 unlock을 호출해요.

매개변수

반환값

성공하면 -1을 반환하고, 잠그지 못한 객체가 있으면 그 객체의 0부터 시작하는 인덱스를 반환해요.

예제

다음 예제는 std::try_lock을 사용해서 별도 스레드에서 실행되는 카운터를 주기적으로 합산하고 초기화해요.

#include <chrono>
#include <functional>
#include <iostream>
#include <mutex>
#include <thread>
#include <vector>

int main()
{
    int foo_count = 0;
    std::mutex foo_count_mutex;
    int bar_count = 0;
    std::mutex bar_count_mutex;
    int overall_count = 0;
    bool done = false;
    std::mutex done_mutex;

    auto increment = [](int& counter, std::mutex& m, const char* desc)
    {
        for (int i = 0; i < 10; ++i)
        {
            std::unique_lock<std::mutex> lock(m);
            ++counter;
            std::cout << desc << ": " << counter << '\n';
            lock.unlock();
            std::this_thread::sleep_for(std::chrono::seconds(1));
        }
    };

    std::thread increment_foo(increment, std::ref(foo_count), 
        std::ref(foo_count_mutex), "foo");
    std::thread increment_bar(increment, std::ref(bar_count), 
        std::ref(bar_count_mutex), "bar");

    std::thread update_overall([&]()
    {
        done_mutex.lock();
        while (!done)
        {
            done_mutex.unlock();
            int result = std::try_lock(foo_count_mutex, bar_count_mutex);
            if (result == -1)
            {
                overall_count += foo_count + bar_count;
                foo_count = 0;
                bar_count = 0;
                std::cout << "overall: " << overall_count << '\n';
                foo_count_mutex.unlock();
                bar_count_mutex.unlock();
            }
            std::this_thread::sleep_for(std::chrono::seconds(2));
            done_mutex.lock();
        }
        done_mutex.unlock();
    });

    increment_foo.join();
    increment_bar.join();
    done_mutex.lock();
    done = true;
    done_mutex.unlock();
    update_overall.join();

    std::cout << "Done processing\n"
              << "foo: " << foo_count << '\n'
              << "bar: " << bar_count << '\n'
              << "overall: " << overall_count << '\n';
}

가능한 출력 결과는 다음과 같아요.

bar: 1
foo: 1
foo: 2
bar: 2
foo: 3
overall: 5
bar: 1
foo: 1
bar: 2
foo: 2
bar: 3
overall: 10
bar: 1
foo: 1
bar: 2
foo: 2
overall: 14
bar: 1
foo: 1
bar: 2
overall: 17
foo: 1
bar: 1
foo: 2
overall: 20
Done processing
foo: 0
bar: 0
overall: 20

같이 보기

더 알아보기 (Learn more)

cppreference