cpp-taskflow/taskflow/core/topology.hpp at cpp14 · gicho/cpp-taskflow · GitHub

Repository navigation

History

74 lines (51 loc) · 1.46 KB

Raw

#pragma once

//#include "taskflow.hpp"

namespace tf {

// ----------------------------------------------------------------------------

// class: Topology

class Topology {

friend class Taskflow;

friend class Executor;

public:

template <typename P, typename C>

Topology(Taskflow&, P&&, C&&);

private:

Taskflow& _taskflow;

std::promise<void> _promise;

PassiveVector<Node*> _sources;

std::atomic<int> _num_sinks {0};

int _cached_num_sinks {0};

std::function<bool()> _pred;

std::function<void()> _call;

void _bind(Graph& g);

void _recover_num_sinks();

};

// Constructor

template <typename P, typename C>

inline Topology::Topology(Taskflow& tf, P&& p, C&& c):

_taskflow(tf),

_pred {std::forward<P>(p)},

_call {std::forward<C>(c)} {

}

// Procedure: _bind

// Re-builds the source links and the sink number for this topology.

inline void Topology::_bind(Graph& g) {

_num_sinks = 0;

_sources.clear();

// scan each node in the graph and build up the links

for(auto& node : g.nodes()) {

node->_topology = this;

if(node->num_dependents() == 0) {

_sources.push_back(node.get());

}

if(node->num_successors() == 0) {

_num_sinks++;

}

_cached_num_sinks = _num_sinks;

}

// Procedure: _recover_num_sinks

inline void Topology::_recover_num_sinks() {

_num_sinks = _cached_num_sinks;

}

} // end of namespace tf. ----------------------------------------------------

cpp-taskflow/taskflow/core/topology.hpp at cpp14 · gicho/cpp-taskflow · GitHub

Repository navigation

Expand file tree

Breadcrumbs

topology.hpp

Latest commit

History

Breadcrumbs

topology.hpp

File metadata and controls