mirror of
https://github.com/barkeser2002/flower.git
synced 2026-09-25 22:18:44 +03:00
57 lines
1.0 KiB
C++
57 lines
1.0 KiB
C++
#pragma once
|
|
|
|
namespace tf {
|
|
|
|
// ----------------------------------------------------------------------------
|
|
|
|
// class: TopologyBase
|
|
class TopologyBase {
|
|
|
|
friend class Executor;
|
|
friend class Node;
|
|
|
|
template <typename T>
|
|
friend class Future;
|
|
|
|
protected:
|
|
|
|
std::atomic<bool> _is_cancelled { false };
|
|
};
|
|
|
|
// ----------------------------------------------------------------------------
|
|
|
|
// class: Topology
|
|
class Topology : public TopologyBase {
|
|
|
|
friend class Executor;
|
|
friend class Runtime;
|
|
|
|
public:
|
|
|
|
template <typename P, typename C>
|
|
Topology(Taskflow&, P&&, C&&);
|
|
|
|
private:
|
|
|
|
Taskflow& _taskflow;
|
|
|
|
std::promise<void> _promise;
|
|
|
|
SmallVector<Node*> _sources;
|
|
|
|
std::function<bool()> _pred;
|
|
std::function<void()> _call;
|
|
|
|
std::atomic<size_t> _join_counter {0};
|
|
};
|
|
|
|
// Constructor
|
|
template <typename P, typename C>
|
|
Topology::Topology(Taskflow& tf, P&& p, C&& c):
|
|
_taskflow(tf),
|
|
_pred {std::forward<P>(p)},
|
|
_call {std::forward<C>(c)} {
|
|
}
|
|
|
|
} // end of namespace tf. ----------------------------------------------------
|