coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2025-12-06 16:56:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

more work

Browse Source
This commit is contained in:
Denis Blank 2015-07-02 19:25:46 +02:00 committed by Naios
parent dc29a2276c
commit 2bae5caef0
1 changed files with 34 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
include/Continuable.h
View File

@ -509,6 +509,26 @@ namespace detail
Callback<_RTy...> callback; Callback<_RTy...> callback;
std::mutex lock;
template <typename Sequence, std::size_t Offset>
struct result_store_sequencer;
template <std::size_t... Sequence, std::size_t Offset>
struct result_store_sequencer<fu::sequence<Sequence...>, Offset>
{
// Do nothing
inline static void store(std::tuple<_RTy...>& result)
{
}
// Store the args in the result tuple
template<typename... Args>
inline static void store(std::tuple<_RTy...>& result, Args&&... args)
{
}
};
public: public:
ResultStorage(std::size_t partitions, Callback<_RTy...> callback_) ResultStorage(std::size_t partitions, Callback<_RTy...> callback_)
: partitions_left(partitions), callback(callback_) { } : partitions_left(partitions), callback(callback_) { }
@ -516,8 +536,21 @@ namespace detail
template<std::size_t Position, typename... Args> template<std::size_t Position, typename... Args>
void store_result(Args&&... args) void store_result(Args&&... args)
{ {
result_store_sequencer<
fu::sequence_of_t<sizeof...(Args)>,
Position
>::store(result, std::forward<Args>(args)...);
} // TODO Improve the lock here
std::lock_guard<std::mutex> guard(lock);
{
// If all partitions have completed invoke the final callback.
if (--partitions_left == 0)
{
}
}
}
}; };
typedef std::shared_ptr<ResultStorage> shared_result_t; typedef std::shared_ptr<ResultStorage> shared_result_t;