mirror of
https://github.com/vcmi/vcmi.git
synced 2025-06-15 00:05:02 +02:00
41 lines
645 B
C++
41 lines
645 B
C++
|
/*
|
||
|
|
* AsyncRunner.h, part of VCMI engine
|
||
|
|
*
|
||
|
|
* Authors: listed in file AUTHORS in main folder
|
||
|
|
*
|
||
|
|
* License: GNU General Public License v2.0 or later
|
||
|
|
* Full text of license available in license.txt file, in main folder
|
||
|
|
*
|
||
|
|
*/
|
||
|
|
#pragma once
|
||
|
|
|
||
|
|
#include <tbb/task_group.h>
|
||
|
|
#include <tbb/task_arena.h>
|
||
|
|
|
||
|
|
VCMI_LIB_NAMESPACE_BEGIN
|
||
|
|
|
||
|
|
class AsyncRunner : boost::noncopyable
|
||
|
|
{
|
||
|
|
tbb::task_arena arena;
|
||
|
|
tbb::task_group taskGroup;
|
||
|
|
|
||
|
|
public:
|
||
|
|
template <typename Functor>
|
||
|
|
void run(Functor && f)
|
||
|
|
{
|
||
|
|
arena.enqueue(taskGroup.defer(std::forward<Functor>(f)));
|
||
|
|
}
|
||
|
|
|
||
|
|
void wait()
|
||
|
|
{
|
||
|
|
taskGroup.wait();
|
||
|
|
}
|
||
|
|
|
||
|
|
~AsyncRunner()
|
||
|
|
{
|
||
|
|
wait();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
VCMI_LIB_NAMESPACE_END
|