blob: f964d2dc88738f1b7d3871011c60d69acd796442 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
#pragma once
#include "future.h"
#include <util/generic/function.h>
#include <util/thread/pool.h>
namespace NThreading {
/**
* @brief Asynchronously executes @arg func in @arg queue returning a future for the result.
*
* @arg func should be a callable object with signature T().
* @arg queue where @arg will be executed
* @returns For @arg func with signature T() the function returns TFuture<T> unless T is TFuture<U>.
* In this case the function returns TFuture<U>.
*
* If you want to use another queue for execution just write an overload, @see ExtensionExample
* unittest.
*/
template <typename Func>
TFuture<TFutureType<TFunctionResult<Func>>> Async(Func&& func, IThreadPool& queue) {
auto promise = NewPromise<TFutureType<TFunctionResult<Func>>>();
auto lambda = [promise, func = std::forward<Func>(func)]() mutable {
NImpl::SetValue(promise, func);
};
queue.SafeAddFunc(std::move(lambda));
return promise.GetFuture();
}
}
|
