std::async

 

C++

Поддержка компилятором

Автономные и размещённые реализации

Язык

Стандартная библиотека

Заголовки стандартной библиотеки

Требования к именованию

Макросы тестирования функциональности (C++20)

Поддержка языка

Библиотека концептов(C++20)

Библиотека метапрограммирования(C++11)

Библиотека диагностики

Библиотека общих утилит

Библиотека строк

Библиотека контейнеров

Библиотека итераторов

Библиотека диапазонов(C++20)

Библиотека алгоритмов

Библиотека численных данных

Библиотека ввода/вывода

Библиотека локализаций

Регулярные выражения(C++11)

Атомарные операции(C++11)

Библиотека поддержки конкуренции(C++11)

Библиотека файловой системы(C++17)

Технические спецификации

Указатель символов

Внешние библиотеки

 

Библиотека поддержки конкуренции

Ветви thread (C++11) jthread (C++20) stop_token (C++20) stop_source (C++20) stop_callback (C++20) hardware_destructive_interference_sizehardware_constructive_interference_size (C++17)(C++17) Пространство имён this_thread get_id (C++11) yield (C++11) sleep_for (C++11) sleep_until (C++11) Атомарные типы atomic (C++11) atomic_ref (C++20) atomic_flag (C++11) Инициализация атомарных типов atomic_init (C++11)(устарело в C++20) ATOMIC_VAR_INIT (C++11)(устарело в C++20) ATOMIC_FLAG_INIT (C++11)(устарело в C++20) Функции освобождения для атомарных операций atomic_storeatomic_store_explicit (C++11)(C++11) atomic_loadatomic_load_explicit (C++11)(C++11) atomic_exchangeatomic_exchange_explicit (C++11)(C++11) atomic_compare_exchange_weakatomic_compare_exchange_weak_explicitatomic_compare_exchange_strongatomic_compare_exchange_strong_explicit (C++11)(C++11)(C++11)(C++11) atomic_fetch_addatomic_fetch_add_explicit (C++11)(C++11) atomic_fetch_subatomic_fetch_sub_explicit (C++11)(C++11) atomic_fetch_andatomic_fetch_and_explicit (C++11)(C++11) atomic_fetch_oratomic_fetch_or_explicit (C++11)(C++11) atomic_fetch_xoratomic_fetch_xor_explicit (C++11)(C++11) atomic_is_lock_free (C++11) atomic_waitatomic_wait_explicit (C++20)(C++20) atomic_notify_one (C++20) atomic_notify_all (C++20)

Функции освобождения для атомарных флагов atomic_flag_test_and_setatomic_flag_test_and_set_explicit (C++11)(C++11) atomic_flag_clearatomic_flag_clear_explicit (C++11)(C++11) atomic_flag_testatomic_flag_test_explicit (C++20)(C++20) atomic_flag_waitatomic_flag_wait_explicit (C++20)(C++20) atomic_flag_notify_one (C++20) atomic_flag_notify_all (C++20) Упорядочивание памяти memory_order (C++11) kill_dependency (C++11) atomic_thread_fence (C++11) atomic_signal_fence (C++11) Взаимное исключение mutex (C++11) recursive_mutex (C++11) shared_mutex (C++17) timed_mutex (C++11) recursive_timed_mutex (C++11) shared_timed_mutex (C++14) Общее управление блокировкой lock_guard (C++11) scoped_lock (C++17) unique_lock (C++11) shared_lock (C++14) defer_lock_ttry_to_lock_tadopt_lock_t (C++11)(C++11)(C++11) lock (C++11) try_lock (C++11) defer_locktry_to_lockadopt_lock (C++11)(C++11)(C++11) once_flag (C++11) call_once (C++11) Условные переменные condition_variable (C++11) condition_variable_any (C++11) notify_all_at_thread_exit (C++11) cv_status (C++11) Семафоры counting_semaphorebinary_semaphore (C++20)(C++20) Защёлки и барьеры latch (C++20) barrier (C++20) Фьючерсы promise (C++11) future (C++11) shared_future (C++11) packaged_task (C++11) async (C++11) launch (C++11) future_status (C++11) future_error (C++11) future_category (C++11) future_errc (C++11)

 

Определено в заголовочном файле <future>
template<class Function, class... Args> std::future<typenamestd::result_of<Function(Args...)>::type>     async( Function&& f, Args&&... args);	(1)	(начиная с C++11)
template<class Function, class... Args> std::future<typenamestd::result_of<Function(Args...)>::type>     async(std::launch policy, Function&& f, Args&&... args);	(2)	(начиная с C++11)

async шаблон функции выполняет функцию f асинхронно (возможно, в отдельном потоке) и возвращает std::future, что будет в итоге результат этого вызова функции.

Оригинал:

The template function async runs the function f asynchronously (potentially in a separate thread) and returns a std::future that will eventually hold the result of that function call.

Текст был переведён автоматически используя Переводчик Google.
Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

1)

Ведет себя так же, как async(std::launch::async|std::launch::deferred, f, args...). Иными словами, f может быть запущен в новый поток или он может быть запущен синхронно, когда в результате std::future запрашивается значение.

Оригинал:

Behaves the same as async(std::launch::async|std::launch::deferred, f, args...). In other words, f may be started in a new thread or it may be run synchronously when the resulting std::future is queried for a value.

Текст был переведён автоматически используя Переводчик Google.
Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

2)

Вызывает функцию f с аргументами args в соответствии с определенной политикой запуск policy

Оригинал:

Calls a function f with arguments args according to a specific launch policy policy:

Текст был переведён автоматически используя Переводчик Google.
Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

• Если' асинхронных флаг установлен (т.е. policy &std::launch::async!=0), то async порождает новый поток исполнения, как по std::thread(f, args...), за исключением того, что если функция f возвращает значение или генерирует исключение, оно хранится в общем состоянии доступным через std::future, что async возвращается к вызывающему.

  Оригинал:

  If the async flag is set (i.e. policy &std::launch::async!=0), then async spawns a new thread of execution as if by std::thread(f, args...), except that if the function f returns a value or throws an exception, it is stored in the shared state accessible through the std::future that async returns to the caller.

  Текст был переведён автоматически используя Переводчик Google.
  Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

• Если отложенный' флаг установлен (т.е. policy &std::launch::deferred!=0), то async новообращенных args... же, как и конструктором std::thread, но не породить новый поток выполнения. Вместо этого,' ленивая оценка производится: при первом вызове, не приурочен ждать функции на std::future, что async возвращается вызывающему вызовет f(args...) должны быть выполнены в текущем потоке. Все последующие обращения к той же std::future будет возвращать результат сразу.

  Оригинал:

  If the deferred flag is set (i.e. policy &std::launch::deferred!=0), then async converts args... the same way as by std::thread constructor, but does not spawn a new thread of execution. Instead, lazy evaluation is performed: the first call to a non-timed wait function on the std::future that async returned to the caller will cause f(args...) to be executed in the current thread. All further accesses to the same std::future will return the result immediately.

  Текст был переведён автоматически используя Переводчик Google.
  Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

• Если оба std::launch::async и std::launch::deferred флаги установлены в policy, это до реализации, выполнять ли асинхронное выполнение или ленивые вычисления.

  Оригинал:

  If both the std::launch::async and std::launch::deferred flags are set in policy, it is up to the implementation whether to perform asynchronous execution or lazy evaluation.

  Текст был переведён автоматически используя Переводчик Google.
  Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

Параметры

f	—	вызываемая функция или функция объекта Оригинал: function or function object to call Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.
args...	—	параметры для передачи f Оригинал: parameters to pass to f Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.
policy	—	битовой маски значение, где отдельные биты управления разрешенные методы исполнения Bit Объяснение Оригинал: Explanation Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда. std::launch::async включить асинхронную оценки Оригинал: enable asynchronous evaluation Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда. std::launch::deferred включить ленивые вычисления Оригинал: enable lazy evaluation Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда. Оригинал: bitmask value, where individual bits control the allowed methods of execution Bit Объяснение Оригинал: Explanation Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда. std::launch::async включить асинхронную оценки Оригинал: enable asynchronous evaluation Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда. std::launch::deferred включить ленивые вычисления Оригинал: enable lazy evaluation Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда. Текст был переведён автоматически используя Переводчик Google. Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

Возвращаемое значение

std::future со ссылкой на возвращаемого значения функции.

Оригинал:

std::future referring to the return value of the function.

Текст был переведён автоматически используя Переводчик Google.
Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

Исключения

Выдает std::system_error с ошибкой std::errc::resource_unavailable_try_again условии, если запуск политика std::launch::async и осуществление не в состоянии начать новую тему.

Оригинал:

Throws std::system_error with error condition std::errc::resource_unavailable_try_again if the launch policy is std::launch::async and the implementation is unable to start a new thread.

Текст был переведён автоматически используя Переводчик Google.
Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

Заметки

Реализация может расширять поведение первой перегрузки std::async путем предоставления дополнительных (осуществление определенных) биты в политику запуска по умолчанию.

Оригинал:

The implementation may extend the behavior of the first overload of std::async by enabling additional (implementation-defined) bits in the default launch policy.

Текст был переведён автоматически используя Переводчик Google.
Вы можете проверить и исправить перевод. Для инструкций щёлкните сюда.

Пример

Запустить этот код

#include <iostream>#include <vector>#include <algorithm>#include <numeric>#include <future>   template<typename RAIter>int parallel_sum(RAIter beg, RAIter end){typename RAIter::difference_type len = end-beg;if(len <1000)returnstd::accumulate(beg, end, 0);   RAIter mid = beg + len/2;auto handle = std::async(std::launch::async, parallel_sum<RAIter>, mid, end);int sum = parallel_sum(beg, mid);return sum + handle.get();}   int main(){std::vector<int> v(10000, 1);std::cout<<"The sum is "<< parallel_sum(v.begin(), v.end())<<'\n';}

Вывод:

The sum is 10000