Làm thế nào để kết hợp việc sử dụng std :: ràng buộc với std :: shared_ptr

Question

tôi cần phải làm một cái gì đó như thế này hơn thường:

AsyncOperation * pAsyncOperation = new AsyncOperation(); 
auto bindOperation = std::bind(&AsyncOperation::operator(), std::ref(*pAsyncOperation)); 
std::thread thread(bindOperation); 
thread.join(); 

với AsyncOperation là bất kỳ lớp tùy chỉnh thực hiện operator()(còn gọi là functor hoặc đối tượng hàm).

Có thể chỉ định cho std::bind để sử dụng số std::shared_ptr thay vì std::ref? Điều này sẽ ngăn chặn rò rỉ bộ nhớ, mà không cần phải giữ tham chiếu trên pAsyncOperation và tự động xóa AsyncOperation ở cuối chuỗi, đó là kết thúc của tác vụ không đồng bộ này.

EDIT: Tôi không phải lúc nào cũng có quyền truy cập vào std :: thread, thư viện chủ đề có thể được tăng :: thread hoặc thậm chí bất kỳ chủ đề phụ thuộc nền tảng nào khác. Và do hậu quả, không truy cập vào std :: async.

Vấn đề chính của tôi là có khái niệm sở hữu trong tiêu chuẩn std :: bind.

Answer 1

này hoạt động:

struct AsyncOperation { 
    void operator()() 
    { 
     std::cout << "AsyncOperation" << '\n'; 
    } 
}; 

int main() { 
    std::shared_ptr<AsyncOperation> pAsyncOperation = std::make_shared<AsyncOperation>(); 
    auto bindOperation = std::bind(&AsyncOperation::operator(), pAsyncOperation); 
    std::thread thread(bindOperation); 
    thread.join(); 
} 

Xem: http://liveworkspace.org/code/4bc81bb6c31ba7b2bdeb79ea0e02bb89

Answer 2

Bạn có cần AsyncOperation để được phân bổ động không? Nếu không, tôi sẽ làm điều đó:

auto f = std::async([]{ AsyncOperation()(); }); 
f.wait(); 

khác:

std::unique_ptr<AsyncOperation> op(new AsyncOperation); 
auto f = std::async([&]{ (*op)(); }); 
f.wait(); 

Bạn có thể sử dụng tất nhiên std::thread, nhưng nó có thể cung cấp thêm các vấn đề (ví dụ: xử lý ngoại lệ trong chủ đề khác). std::bind cũng có những vấn đề riêng của nó và bạn có thể sẽ kết thúc tốt hơn với một lambda.

Nếu bạn thực sự cần phải vượt qua một quyền sở hữu cho chủ đề khác mà bạn cũng có thể làm điều đó:

std::unique_ptr<AsyncOperation> op(new AsyncOperation); 
auto f = std::async([&](std::unique_ptr<AsyncOperation> op){ (*op)(); }, std::move(op)); 
f.wait(); 

như lambdas không hỗ trợ loại di chuyển chụp được nêu ra.

Tôi hy vọng điều đó sẽ hữu ích.