Namespaces
Variants
Views
Actions

Difference between revisions of "cpp/thread/packaged task"

From cppreference.com
< cpp‎ | thread
m (Text replace - "{{concept" to "{{named req")
m (fmt, headers sorted)
 
(5 intermediate revisions by 4 users not shown)
Line 2: Line 2:
 
{{cpp/thread/packaged_task/navbar}}
 
{{cpp/thread/packaged_task/navbar}}
 
{{dcl begin}}
 
{{dcl begin}}
−
{{dcl header | future}}
+
{{dcl header|future}}
−
{{dcl | num=1 | since=c++11 |
+
{{dcl|num=1|since=c++11|
 
template< class > class packaged_task; //not defined
 
template< class > class packaged_task; //not defined
 
}}
 
}}
−
{{dcl | num=2 | since=c++11 |
+
{{dcl|num=2|since=c++11|
−
template< class R, class ...Args >  
+
template< class R, class ...ArgTypes >  
−
class packaged_task<R(Args...)>;
+
class packaged_task<R(ArgTypes...)>;
 
}}
 
}}
 
{{dcl end}}
 
{{dcl end}}
  
−
The class template {{tt|std::packaged_task}} wraps any {{named req|Callable}} target (function, lambda expression, bind expression, or another function object) so that it can be invoked asynchronously. Its return value or exception thrown is stored in a shared state which can be accessed through {{lc|std::future}} objects.
+
The class template {{tt|std::packaged_task}} wraps any {{named req|Callable}} target (function, lambda expression, bind expression, or another function object) so that it can be invoked asynchronously. Its return value or exception thrown is stored in a shared state which can be accessed through {{lc|std::future}} objects.
  
 
{{rrev|until=c++17|
 
{{rrev|until=c++17|
Line 20: Line 20:
 
===Member functions===
 
===Member functions===
 
{{dsc begin}}
 
{{dsc begin}}
−
{{dsc inc | cpp/thread/packaged_task/dsc constructor}}
+
{{dsc inc|cpp/thread/packaged_task/dsc constructor}}
−
{{dsc inc | cpp/thread/packaged_task/dsc destructor}}
+
{{dsc inc|cpp/thread/packaged_task/dsc destructor}}
−
{{dsc inc | cpp/thread/packaged_task/dsc operator{{=}}}}
+
{{dsc inc|cpp/thread/packaged_task/dsc operator{{=}}}}
−
{{dsc inc | cpp/thread/packaged_task/dsc valid}}
+
{{dsc inc|cpp/thread/packaged_task/dsc valid}}
−
{{dsc inc | cpp/thread/packaged_task/dsc swap}}
+
{{dsc inc|cpp/thread/packaged_task/dsc swap}}
  
−
{{dsc h2 | Getting the result}}
+
{{dsc h2|Getting the result}}
−
{{dsc inc | cpp/thread/packaged_task/dsc get_future}}
+
{{dsc inc|cpp/thread/packaged_task/dsc get_future}}
  
−
{{dsc h2 | Execution}}
+
{{dsc h2|Execution}}
−
{{dsc inc | cpp/thread/packaged_task/dsc operator()}}
+
{{dsc inc|cpp/thread/packaged_task/dsc operator()}}
−
{{dsc inc | cpp/thread/packaged_task/dsc make_ready_at_thread_exit}}
+
{{dsc inc|cpp/thread/packaged_task/dsc make_ready_at_thread_exit}}
−
{{dsc inc | cpp/thread/packaged_task/dsc reset}}
+
{{dsc inc|cpp/thread/packaged_task/dsc reset}}
 
{{dsc end}}
 
{{dsc end}}
  
 
===Non-member functions===
 
===Non-member functions===
 
{{dsc begin}}
 
{{dsc begin}}
−
{{dsc inc | cpp/thread/packaged_task/dsc swap2}}
+
{{dsc inc|cpp/thread/packaged_task/dsc swap2}}
 
{{dsc end}}
 
{{dsc end}}
  
 
===Helper classes===
 
===Helper classes===
 
{{dsc begin}}
 
{{dsc begin}}
−
{{dsc inc | cpp/thread/packaged_task/dsc uses_allocator}}
+
{{dsc inc|cpp/thread/packaged_task/dsc uses_allocator}}
 
{{dsc end}}
 
{{dsc end}}
 +
 +
==={{rl|deduction_guides|Deduction guides}}{{mark since c++17}}===
  
 
===Example===
 
===Example===
 
{{example
 
{{example
−
| code=
+
|code=
−
#include <iostream>
+
 
#include <cmath>
 
#include <cmath>
−
#include <thread>
 
−
#include <future>
 
 
#include <functional>
 
#include <functional>
 +
#include <future>
 +
#include <iostream>
 +
#include <thread>
  
 
// unique function to avoid disambiguating the std::pow overload set
 
// unique function to avoid disambiguating the std::pow overload set
−
int f(int x, int y) { return std::pow(x,y); }
+
int f(int x, int y) { return std::pow(x, y); }
  
 
void task_lambda()
 
void task_lambda()
 
{
 
{
−
     std::packaged_task<int(int,int)> task([](int a, int b) {
+
     std::packaged_task<int(int, int)> task([](int a, int b)
 +
    {
 
         return std::pow(a, b);  
 
         return std::pow(a, b);  
 
     });
 
     });
Line 81: Line 84:
 
void task_thread()
 
void task_thread()
 
{
 
{
−
     std::packaged_task<int(int,int)> task(f);
+
     std::packaged_task<int(int, int)> task(f);
 
     std::future<int> result = task.get_future();
 
     std::future<int> result = task.get_future();
 
 
Line 96: Line 99:
 
     task_thread();
 
     task_thread();
 
}
 
}
−
| output=
+
|output=
 
task_lambda: 512
 
task_lambda: 512
 
task_bind:  2048
 
task_bind:  2048
 
task_thread: 1024
 
task_thread: 1024
 
}}
 
}}
 +
 +
===Defect reports===
 +
{{dr list begin}}
 +
{{dr list item|wg=lwg|dr=3117|std=C++17|before=deduction guides for {{tt|packaged_task}} were missing|after=added}}
 +
{{dr list end}}
  
 
===See also===
 
===See also===
 
{{dsc begin}}
 
{{dsc begin}}
−
{{dsc inc | cpp/thread/dsc future}}
+
{{dsc inc|cpp/thread/dsc future}}
 
{{dsc end}}
 
{{dsc end}}
  
−
[[de:cpp/thread/packaged task]]
+
{{langlinks|de|es|fr|it|ja|pt|ru|zh}}
−
[[es:cpp/thread/packaged task]]
+
−
[[fr:cpp/thread/packaged task]]
+
−
[[it:cpp/thread/packaged task]]
+
−
[[ja:cpp/thread/packaged task]]
+
−
[[pt:cpp/thread/packaged task]]
+
−
[[ru:cpp/thread/packaged task]]
+
−
[[zh:cpp/thread/packaged task]]
+

Latest revision as of 02:02, 23 October 2023

 
C++
 
Concurrency support library
Threads
(C++11)
(C++20)
(C++17)(C++17)
this_thread namespace
(C++11)
(C++11)
(C++11)
(C++11)
Cooperative cancellation
Mutual exclusion
(C++11)
(C++11)
(C++17)
Generic lock management
(C++11)
(C++11)
(C++17)
(C++11)
(C++14)
(C++11)
(C++11)
(C++11)
(C++11)(C++11)(C++11)(C++11)(C++11)(C++11)
Condition variables
(C++11)
(C++11)
(C++11)
(C++11)
Semaphores
(C++20)(C++20)
Latches and Barriers
(C++20)
(C++20)
Futures
(C++11)
(C++11)
(C++11)
packaged_task
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
Safe Reclamation
(C++26)
(C++26)
(C++26)
Hazard Pointers
(C++26)
(C++26)
(C++26)
Atomic types
(C++11)
(C++20)
(C++11)
Initialization of atomic types
(C++11)(deprecated in C++20)
(C++11)(deprecated in C++20)
(C++11)
Memory ordering
(C++11)
(C++11)
(C++11)
(C++11)
Free functions for atomic operations
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++26)(C++26)
(C++26)(C++26)
(C++11)
(C++20)(C++20)
(C++20)
(C++20)
Free functions for atomic flags
(C++11)(C++11)
(C++11)(C++11)
(C++20)(C++20)
(C++20)(C++20)
(C++20)
(C++20)
 
std::packaged_task
 
Defined in header <future>
template< class > class packaged_task; //not defined
 (1) (since C++11)
template< class R, class ...ArgTypes >
class packaged_task<R(ArgTypes...)>;
 (2) (since C++11)

The class template std::packaged_task wraps any Callable target (function, lambda expression, bind expression, or another function object) so that it can be invoked asynchronously. Its return value or exception thrown is stored in a shared state which can be accessed through std::future objects.

Just like std::function, std::packaged_task is a polymorphic, allocator-aware container: the stored callable target may be allocated on heap or with a provided allocator.

(until C++17)

Contents

[edit] Member functions

 constructs the task object
(public member function) [edit]
destructs the task object
(public member function) [edit]
moves the task object
(public member function) [edit]
checks if the task object has a valid function
(public member function) [edit]
swaps two task objects
(public member function) [edit]
Getting the result
returns a std::future associated with the promised result
(public member function) [edit]
Execution
executes the function
(public member function) [edit]
executes the function ensuring that the result is ready only once the current thread exits
(public member function) [edit]
resets the state abandoning any stored results of previous executions
(public member function) [edit]

[edit] Non-member functions

(C++11)
 specializes the std::swap algorithm
(function template) [edit]

[edit] Helper classes

(C++11) (until C++17)
 specializes the std::uses_allocator type trait
(class template specialization) [edit]

[edit] Deduction guides(since C++17)

[edit] Example

Run this code
#include <cmath>
#include <functional>
#include <future>
#include <iostream>
#include <thread>
 
// unique function to avoid disambiguating the std::pow overload set
int f(int x, int y) { return std::pow(x, y); }
 
void task_lambda()
{
    std::packaged_task<int(int, int)> task([](int a, int b)
    {
        return std::pow(a, b); 
    });
    std::future<int> result = task.get_future();
 
    task(2, 9);
 
    std::cout << "task_lambda:\t" << result.get() << '\n';
}
 
void task_bind()
{
    std::packaged_task<int()> task(std::bind(f, 2, 11));
    std::future<int> result = task.get_future();
 
    task();
 
    std::cout << "task_bind:\t" << result.get() << '\n';
}
 
void task_thread()
{
    std::packaged_task<int(int, int)> task(f);
    std::future<int> result = task.get_future();
 
    std::thread task_td(std::move(task), 2, 10);
    task_td.join();
 
    std::cout << "task_thread:\t" << result.get() << '\n';
}
 
int main()
{
    task_lambda();
    task_bind();
    task_thread();
}

Output: 

task_lambda: 512
task_bind:   2048
task_thread: 1024

[edit] Defect reports

The following behavior-changing defect reports were applied retroactively to previously published C++ standards.

DR Applied to Behavior as published Correct behavior
LWG 3117 C++17 deduction guides for packaged_task were missing added

[edit] See also

(C++11)
 waits for a value that is set asynchronously
(class template) [edit]
Retrieved from "https://en.cppreference.com/mwiki/index.php?title=cpp/thread/packaged_task&oldid=161199"