std::async

 

C++

Язык

Понятия (концепции)

Утилиты

Строки

Контейнеры

Алгоритмы

Итераторы

Работа с числами

Ввод / вывод

Локализация

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

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

Потоки (C++11)

 

Библиотека поддержки потоков

Потоки Оригинал: Threads Текст был переведён автоматически через Google Translate. Вы можете проверить и исправить перевод. Для инструкций кликните сюда.
thread (C++11)
this_thread имен Оригинал: this_thread namespace Текст был переведён автоматически через Google Translate. Вы можете проверить и исправить перевод. Для инструкций кликните сюда.
get_id (C++11) yield (C++11)	sleep_for (C++11) sleep_until (C++11)
Взаимное исключение Оригинал: Mutual exclusion Текст был переведён автоматически через Google Translate. Вы можете проверить и исправить перевод. Для инструкций кликните сюда.
mutex (C++11) timed_mutex (C++11)	recursive_mutex (C++11) recursive_timed_mutex (C++11)
Generic управления замком Оригинал: Generic lock management Текст был переведён автоматически через Google Translate. Вы можете проверить и исправить перевод. Для инструкций кликните сюда.
lock_guard (C++11) unique_lock (C++11) defer_lock_t try_to_lock_t adopt_lock_t (C++11) (C++11) (C++11)	lock (C++11) try_lock (C++11) defer_lock try_to_lock adopt_lock (C++11) (C++11) (C++11)
Условия переменных Оригинал: Condition variables Текст был переведён автоматически через Google Translate. Вы можете проверить и исправить перевод. Для инструкций кликните сюда.
condition_variable (C++11)
condition_variable_any (C++11)
notify_all_at_thread_exit (C++11)
cv_status (C++11)
Futures Оригинал: Futures Текст был переведён автоматически через Google Translate. Вы можете проверить и исправить перевод. Для инструкций кликните сюда.
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<typename std::result_of<Function(Args...)>::type>     async( Function&& f, Args&&... args );	(1)	(начиная с C++11)
template< class Function, class... Args > std::future<typename std::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 Translate.
Вы можете проверить и исправить перевод. Для инструкций кликните сюда.

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 Translate.
Вы можете проверить и исправить перевод. Для инструкций кликните сюда.

2)

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

Оригинал:

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

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

• Если' асинхронных флаг установлен (т.е. 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 Translate.
  Вы можете проверить и исправить перевод. Для инструкций кликните сюда.

• Если отложенный' флаг установлен (т.е. 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 Translate.
  Вы можете проверить и исправить перевод. Для инструкций кликните сюда.

• Если оба 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 Translate.
  Вы можете проверить и исправить перевод. Для инструкций кликните сюда.

Параметры

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

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

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

Оригинал:

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

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

Исключения

Выдает 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 Translate.
Вы можете проверить и исправить перевод. Для инструкций кликните сюда.

Notes

Реализация может расширять поведение первой перегрузки 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 Translate.
Вы можете проверить и исправить перевод. Для инструкций кликните сюда.

Пример

#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)
        return std::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