tbb::flow::interface10::graph Class Reference

The graph class. More...

#include <_flow_graph_impl.h>

Inheritance diagram for tbb::flow::interface10::graph:

Collaboration diagram for tbb::flow::interface10::graph:

Classes
class	run_and_put_task
class	run_task
class	spawn_functor
	A functor that spawns a task. More...
class	wait_functor

Public Types
typedef tbb::flow::interface11::graph_iterator< graph, tbb::flow::interface11::graph_node >	iterator
typedef tbb::flow::interface11::graph_iterator< const graph, const tbb::flow::interface11::graph_node >	const_iterator

Public Member Functions
	graph ()
	Constructs a graph with isolated task_group_context. More...
	graph (tbb::task_group_context &use_this_context)
	Constructs a graph with use_this_context as context. More...
	~graph ()
	Destroys the graph. More...
__TBB_DEPRECATED void	increment_wait_count ()
__TBB_DEPRECATED void	decrement_wait_count ()
void	reserve_wait () __TBB_override
	Used to register that an external entity may still interact with the graph. More...
void	release_wait () __TBB_override
	Deregisters an external entity that may have interacted with the graph. More...
template<typename Receiver , typename Body >
__TBB_DEPRECATED void	run (Receiver &r, Body body)
	Spawns a task that runs a body and puts its output to a specific receiver. More...
template<typename Body >
__TBB_DEPRECATED void	run (Body body)
	Spawns a task that runs a function object. More...
void	wait_for_all ()
	Wait until graph is idle and decrement_wait_count calls equals increment_wait_count calls. More...
__TBB_DEPRECATED tbb::task *	root_task ()
	Returns the root task of the graph. More...
iterator	begin ()
	start iterator More...
iterator	end ()
	end iterator More...
const_iterator	begin () const
	start const iterator More...
const_iterator	end () const
	end const iterator More...
const_iterator	cbegin () const
	start const iterator More...
const_iterator	cend () const
	end const iterator More...
bool	is_cancelled ()
	return status of graph execution More...
bool	exception_thrown ()
void	reset (tbb::flow::interface11::reset_flags f=tbb::flow::interface11::rf_reset_protocol)
Public Member Functions inherited from tbb::flow::interface11::graph_proxy
virtual	~graph_proxy ()

Private Types
typedef std::list< tbb::task * >	task_list_type

Private Member Functions
void	prepare_task_arena (bool reinit=false)
void	register_node (tbb::flow::interface11::graph_node *n)
void	remove_node (tbb::flow::interface11::graph_node *n)
Private Member Functions inherited from tbb::internal::no_copy
	no_copy (const no_copy &)=delete
	no_copy ()=default

Private Attributes
tbb::task *	my_root_task
tbb::task_group_context *	my_context
bool	own_context
bool	cancelled
bool	caught_exception
bool	my_is_active
task_list_type	my_reset_task_list
tbb::flow::interface11::graph_node *	my_nodes
tbb::flow::interface11::graph_node *	my_nodes_last
tbb::spin_mutex	nodelist_mutex
tbb::task_arena *	my_task_arena
tbb::flow::interface11::internal::graph_task_priority_queue_t	my_priority_queue

Friends
class	tbb::flow::interface11::graph_node
template<typename C , typename N >
class	tbb::flow::interface11::graph_iterator
class	tbb::interface7::internal::task_arena_base
void	tbb::flow::interface11::internal::activate_graph (graph &g)
void	tbb::flow::interface11::internal::deactivate_graph (graph &g)
bool	tbb::flow::interface11::internal::is_graph_active (graph &g)
tbb::task &	tbb::flow::interface11::internal::prioritize_task (graph &g, tbb::task &arena_task)
void	tbb::flow::interface11::internal::spawn_in_graph_arena (graph &g, tbb::task &arena_task)
void	tbb::flow::interface11::internal::enqueue_in_graph_arena (graph &g, tbb::task &arena_task)
void	tbb::flow::interface11::internal::add_task_to_graph_reset_list (graph &g, tbb::task *tp)

Detailed Description

The graph class.

This class serves as a handle to the graph

Definition at line 211 of file _flow_graph_impl.h.

Member Typedef Documentation

const_iterator

typedef tbb::flow::interface11::graph_iterator<const graph, const tbb::flow::interface11::graph_node> tbb::flow::interface10::graph::const_iterator

Definition at line 384 of file _flow_graph_impl.h.

iterator

typedef tbb::flow::interface11::graph_iterator<graph, tbb::flow::interface11::graph_node> tbb::flow::interface10::graph::iterator

Definition at line 383 of file _flow_graph_impl.h.

task_list_type

typedef std::list<tbb::task *> tbb::flow::interface10::graph::task_list_type

private

Definition at line 246 of file _flow_graph_impl.h.

Constructor & Destructor Documentation

graph() [1/2]

tbb::flow::interface10::graph::graph ( )

inline

Constructs a graph with isolated task_group_context.

Definition at line 774 of file flow_graph.h.

                    : my_nodes(NULL), my_nodes_last(NULL), my_task_arena(NULL) {
    prepare_task_arena();
    own_context = true;
    cancelled = false;
    caught_exception = false;
    my_context = new task_group_context(tbb::internal::FLOW_TASKS);
    my_root_task = (new (task::allocate_root(*my_context)) empty_task);
    my_root_task->set_ref_count(1);
    tbb::internal::fgt_graph(this);
    my_is_active = true;
}

References own_context, and prepare_task_arena().

Here is the call graph for this function:

graph() [2/2]

tbb::flow::interface10::graph::graph ( tbb::task_group_context &  use_this_context )

inlineexplicit

Constructs a graph with use_this_context as context.

Definition at line 786 of file flow_graph.h.

                                                        :
    my_context(&use_this_context), my_nodes(NULL), my_nodes_last(NULL), my_task_arena(NULL) {
    prepare_task_arena();
    own_context = false;
    cancelled = false;
    caught_exception = false;
    my_root_task = (new (task::allocate_root(*my_context)) empty_task);
    my_root_task->set_ref_count(1);
    tbb::internal::fgt_graph(this);
    my_is_active = true;
}

~graph()

tbb::flow::interface10::graph::~graph ( )

inline

Destroys the graph.

Calls wait_for_all, then destroys the root task and context.

Definition at line 798 of file flow_graph.h.

                     {
    wait_for_all();
    my_root_task->set_ref_count(0);
    tbb::task::destroy(*my_root_task);
    if (own_context) delete my_context;
    delete my_task_arena;
}

Member Function Documentation

begin() [1/2]

graph::iterator tbb::flow::interface10::graph::begin ( )

inline

start iterator

Definition at line 866 of file flow_graph.h.

{ return iterator(this, true); }

begin() [2/2]

graph::const_iterator tbb::flow::interface10::graph::begin ( ) const

inline

start const iterator

Definition at line 870 of file flow_graph.h.

{ return const_iterator(this, true); }

cbegin()

graph::const_iterator tbb::flow::interface10::graph::cbegin ( ) const

inline

start const iterator

Definition at line 874 of file flow_graph.h.

{ return const_iterator(this, true); }

cend()

graph::const_iterator tbb::flow::interface10::graph::cend ( ) const

inline

end const iterator

Definition at line 876 of file flow_graph.h.

{ return const_iterator(this, false); }

decrement_wait_count()

__TBB_DEPRECATED void tbb::flow::interface10::graph::decrement_wait_count ( )

inline

Definition at line 299 of file _flow_graph_impl.h.

                                                 {
        release_wait();
    }

References release_wait().

Here is the call graph for this function:

end() [1/2]

graph::iterator tbb::flow::interface10::graph::end ( )

inline

end iterator

Definition at line 868 of file flow_graph.h.

{ return iterator(this, false); }

end() [2/2]

graph::const_iterator tbb::flow::interface10::graph::end ( ) const

inline

end const iterator

Definition at line 872 of file flow_graph.h.

{ return const_iterator(this, false); }

exception_thrown()

bool tbb::flow::interface10::graph::exception_thrown ( )

inline

Definition at line 402 of file _flow_graph_impl.h.

{ return caught_exception; }

References caught_exception.

increment_wait_count()

__TBB_DEPRECATED void tbb::flow::interface10::graph::increment_wait_count ( )

inline

Definition at line 295 of file _flow_graph_impl.h.

                                                 {
        reserve_wait();
    }

References reserve_wait().

Here is the call graph for this function:

is_cancelled()

bool tbb::flow::interface10::graph::is_cancelled ( )

inline

return status of graph execution

Definition at line 401 of file _flow_graph_impl.h.

{ return cancelled; }

References cancelled.

prepare_task_arena()

void tbb::flow::interface10::graph::prepare_task_arena ( bool  reinit = false )

inlineprivate

Definition at line 265 of file _flow_graph_impl.h.

                                                 {
        if (reinit) {
            __TBB_ASSERT(my_task_arena, "task arena is NULL");
            my_task_arena->terminate();
            my_task_arena->initialize(tbb::task_arena::attach());
        }
        else {
            __TBB_ASSERT(my_task_arena == NULL, "task arena is not NULL");
            my_task_arena = new tbb::task_arena(tbb::task_arena::attach());
        }
        if (!my_task_arena->is_active()) // failed to attach
            my_task_arena->initialize(); // create a new, default-initialized arena
        __TBB_ASSERT(my_task_arena->is_active(), "task arena is not active");
    }

References __TBB_ASSERT, tbb::interface7::task_arena::initialize(), tbb::interface7::task_arena::is_active(), my_task_arena, and tbb::interface7::task_arena::terminate().

Referenced by graph().

Here is the call graph for this function:

Here is the caller graph for this function:

register_node()

void tbb::flow::interface10::graph::register_node ( tbb::flow::interface11::graph_node *  n )

inlineprivate

Definition at line 820 of file flow_graph.h.

                                                                {
    n->next = NULL;
    {
        spin_mutex::scoped_lock lock(nodelist_mutex);
        n->prev = my_nodes_last;
        if (my_nodes_last) my_nodes_last->next = n;
        my_nodes_last = n;
        if (!my_nodes) my_nodes = n;
    }
}

References lock, tbb::flow::interface11::graph_node::next, and tbb::flow::interface11::graph_node::prev.

Referenced by tbb::flow::interface11::graph_node::graph_node().

Here is the caller graph for this function:

release_wait()

void tbb::flow::interface10::graph::release_wait ( )

inlinevirtual

Deregisters an external entity that may have interacted with the graph.

The graph will not return from wait_for_all until all the number of decrement_wait_count calls matches the number of increment_wait_count calls.

Implements tbb::flow::interface11::graph_proxy.

Definition at line 813 of file flow_graph.h.

                                {
    if (my_root_task) {
        tbb::internal::fgt_release_wait(this);
        my_root_task->decrement_ref_count();
    }
}

Referenced by decrement_wait_count().

Here is the caller graph for this function:

remove_node()

void tbb::flow::interface10::graph::remove_node ( tbb::flow::interface11::graph_node *  n )

inlineprivate

Definition at line 831 of file flow_graph.h.

                                                              {
    {
        spin_mutex::scoped_lock lock(nodelist_mutex);
        __TBB_ASSERT(my_nodes && my_nodes_last, "graph::remove_node: Error: no registered nodes");
        if (n->prev) n->prev->next = n->next;
        if (n->next) n->next->prev = n->prev;
        if (my_nodes_last == n) my_nodes_last = n->prev;
        if (my_nodes == n) my_nodes = n->next;
    }
    n->prev = n->next = NULL;
}

References __TBB_ASSERT, and lock.

Referenced by tbb::flow::interface11::graph_node::~graph_node().

Here is the caller graph for this function:

reserve_wait()

void tbb::flow::interface10::graph::reserve_wait ( )

inlinevirtual

Used to register that an external entity may still interact with the graph.

The graph will not return from wait_for_all until a matching number of decrement_wait_count calls is made.

Implements tbb::flow::interface11::graph_proxy.

Definition at line 806 of file flow_graph.h.

                                {
    if (my_root_task) {
        my_root_task->increment_ref_count();
        tbb::internal::fgt_reserve_wait(this);
    }
}

Referenced by increment_wait_count().

Here is the caller graph for this function:

reset()

void tbb::flow::interface10::graph::reset ( tbb::flow::interface11::reset_flags  f = tbb::flow::interface11::rf_reset_protocol )

inline

Definition at line 843 of file flow_graph.h.

                                                          {
    // reset context
    tbb::flow::interface11::internal::deactivate_graph(*this);

    if(my_context) my_context->reset();
    cancelled = false;
    caught_exception = false;
    // reset all the nodes comprising the graph
    for(iterator ii = begin(); ii != end(); ++ii) {
        tbb::flow::interface11::graph_node *my_p = &(*ii);
        my_p->reset_node(f);
    }
    // Reattach the arena. Might be useful to run the graph in a particular task_arena
    // while not limiting graph lifetime to a single task_arena::execute() call.
    prepare_task_arena( /*reinit=*/true );
    tbb::flow::interface11::internal::activate_graph(*this);
    // now spawn the tasks necessary to start the graph
    for(task_list_type::iterator rti = my_reset_task_list.begin(); rti != my_reset_task_list.end(); ++rti) {
        tbb::flow::interface11::internal::spawn_in_graph_arena(*this, *(*rti));
    }
    my_reset_task_list.clear();
}

References tbb::flow::interface11::internal::deactivate_graph().

Here is the call graph for this function:

root_task()

__TBB_DEPRECATED tbb::task* tbb::flow::interface10::graph::root_task ( )

inline

Returns the root task of the graph.

Definition at line 374 of file _flow_graph_impl.h.

                                           {
        return my_root_task;
    }

References my_root_task.

Referenced by tbb::flow::interface11::input_node< Output >::create_put_task(), tbb::flow::interface11::limiter_node< T, DecrementType >::forward_task(), tbb::flow::interface11::buffer_node< T, Allocator >::handle_operations_impl(), tbb::flow::interface11::limiter_node< T, DecrementType >::register_predecessor(), tbb::flow::interface11::limiter_node< T, DecrementType >::register_successor(), run(), and tbb::flow::interface11::limiter_node< T, DecrementType >::try_put_task().

Here is the caller graph for this function:

run() [1/2]

template<typename Receiver , typename Body >

__TBB_DEPRECATED void tbb::flow::interface10::graph::run ( Receiver &  r, Body  body  )

inline

Spawns a task that runs a body and puts its output to a specific receiver.

The task is spawned as a child of the graph. This is useful for running tasks that need to block a wait_for_all() on the graph. For example a one-off source.

Definition at line 317 of file _flow_graph_impl.h.

                                                      {
        if (tbb::flow::interface11::internal::is_graph_active(*this)) {
            task* rtask = new (task::allocate_additional_child_of(*root_task()))
                run_and_put_task< Receiver, Body >(r, body);
            my_task_arena->execute(spawn_functor(*rtask));
        }
    }

References tbb::interface7::task_arena::execute(), tbb::flow::interface11::internal::is_graph_active(), my_task_arena, and root_task().

Here is the call graph for this function:

run() [2/2]

template<typename Body >

__TBB_DEPRECATED void tbb::flow::interface10::graph::run ( Body  body )

inline

Spawns a task that runs a function object.

The task is spawned as a child of the graph. This is useful for running tasks that need to block a wait_for_all() on the graph. For example a one-off source.

Definition at line 329 of file _flow_graph_impl.h.

                                         {
        if (tbb::flow::interface11::internal::is_graph_active(*this)) {
            task* rtask = new (task::allocate_additional_child_of(*root_task())) run_task< Body >(body);
            my_task_arena->execute(spawn_functor(*rtask));
        }
    }

References tbb::interface7::task_arena::execute(), tbb::flow::interface11::internal::is_graph_active(), my_task_arena, and root_task().

Here is the call graph for this function:

wait_for_all()

void tbb::flow::interface10::graph::wait_for_all ( )

inline

Wait until graph is idle and decrement_wait_count calls equals increment_wait_count calls.

The waiting thread will go off and steal work while it is block in the wait_for_all.

Definition at line 338 of file _flow_graph_impl.h.

                        {
        cancelled = false;
        caught_exception = false;
        if (my_root_task) {
#if TBB_USE_EXCEPTIONS
            try {
#endif
                my_task_arena->execute(wait_functor(my_root_task));
#if __TBB_TASK_GROUP_CONTEXT
                cancelled = my_context->is_group_execution_cancelled();
#endif
#if TBB_USE_EXCEPTIONS
            }
            catch (...) {
                my_root_task->set_ref_count(1);
                my_context->reset();
                caught_exception = true;
                cancelled = true;
                throw;
            }
#endif
#if __TBB_TASK_GROUP_CONTEXT
            // TODO: the "if" condition below is just a work-around to support the concurrent wait
            // mode. The cancellation and exception mechanisms are still broken in this mode.
            // Consider using task group not to re-implement the same functionality.
            if (!(my_context->traits() & tbb::task_group_context::concurrent_wait)) {
                my_context->reset();  // consistent with behavior in catch()
#endif
                my_root_task->set_ref_count(1);
#if __TBB_TASK_GROUP_CONTEXT
            }
#endif
        }
    }

References cancelled, caught_exception, tbb::task_group_context::concurrent_wait, tbb::interface7::task_arena::execute(), tbb::task_group_context::is_group_execution_cancelled(), my_context, my_root_task, my_task_arena, tbb::task_group_context::reset(), tbb::task::set_ref_count(), and tbb::task_group_context::traits().

Here is the call graph for this function:

Friends And Related Function Documentation

tbb::flow::interface11::graph_iterator

template<typename C , typename N >

friend class tbb::flow::interface11::graph_iterator

friend

Definition at line 380 of file _flow_graph_impl.h.

tbb::flow::interface11::graph_node

friend class tbb::flow::interface11::graph_node

friend

Definition at line 212 of file _flow_graph_impl.h.

tbb::flow::interface11::internal::activate_graph

void tbb::flow::interface11::internal::activate_graph ( graph &  g )

friend

tbb::flow::interface11::internal::add_task_to_graph_reset_list

void tbb::flow::interface11::internal::add_task_to_graph_reset_list ( graph &  g, tbb::task *  tp  )

friend

tbb::flow::interface11::internal::deactivate_graph

void tbb::flow::interface11::internal::deactivate_graph ( graph &  g )

friend

tbb::flow::interface11::internal::enqueue_in_graph_arena

void tbb::flow::interface11::internal::enqueue_in_graph_arena ( graph &  g, tbb::task &  arena_task  )

friend

tbb::flow::interface11::internal::is_graph_active

bool tbb::flow::interface11::internal::is_graph_active ( graph &  g )

friend

tbb::flow::interface11::internal::prioritize_task

tbb::task& tbb::flow::interface11::internal::prioritize_task ( graph &  g, tbb::task &  arena_task  )

friend

tbb::flow::interface11::internal::spawn_in_graph_arena

void tbb::flow::interface11::internal::spawn_in_graph_arena ( graph &  g, tbb::task &  arena_task  )

friend

tbb::interface7::internal::task_arena_base

friend class tbb::interface7::internal::task_arena_base

friend

Definition at line 438 of file _flow_graph_impl.h.

Member Data Documentation

cancelled

bool tbb::flow::interface10::graph::cancelled

private

Definition at line 413 of file _flow_graph_impl.h.

Referenced by is_cancelled(), and wait_for_all().

caught_exception

bool tbb::flow::interface10::graph::caught_exception

private

Definition at line 414 of file _flow_graph_impl.h.

Referenced by exception_thrown(), and wait_for_all().

my_context

tbb::task_group_context* tbb::flow::interface10::graph::my_context

private

Definition at line 410 of file _flow_graph_impl.h.

Referenced by wait_for_all().

my_is_active

bool tbb::flow::interface10::graph::my_is_active

private

Definition at line 415 of file _flow_graph_impl.h.

Referenced by tbb::flow::interface11::internal::activate_graph(), tbb::flow::interface11::internal::deactivate_graph(), and tbb::flow::interface11::internal::is_graph_active().

my_nodes

tbb::flow::interface11::graph_node* tbb::flow::interface10::graph::my_nodes

private

Definition at line 418 of file _flow_graph_impl.h.

my_nodes_last

tbb::flow::interface11::graph_node * tbb::flow::interface10::graph::my_nodes_last

private

Definition at line 418 of file _flow_graph_impl.h.

my_priority_queue

tbb::flow::interface11::internal::graph_task_priority_queue_t tbb::flow::interface10::graph::my_priority_queue

private

Definition at line 427 of file _flow_graph_impl.h.

Referenced by tbb::flow::interface11::internal::prioritize_task().

my_reset_task_list

task_list_type tbb::flow::interface10::graph::my_reset_task_list

private

Definition at line 416 of file _flow_graph_impl.h.

Referenced by tbb::flow::interface11::internal::add_task_to_graph_reset_list().

my_root_task

tbb::task* tbb::flow::interface10::graph::my_root_task

private

Definition at line 408 of file _flow_graph_impl.h.

Referenced by root_task(), and wait_for_all().

my_task_arena

tbb::task_arena* tbb::flow::interface10::graph::my_task_arena

private

Definition at line 424 of file _flow_graph_impl.h.

Referenced by tbb::flow::interface11::internal::enqueue_in_graph_arena(), prepare_task_arena(), run(), tbb::flow::interface11::internal::spawn_in_graph_arena(), and wait_for_all().

nodelist_mutex

tbb::spin_mutex tbb::flow::interface10::graph::nodelist_mutex

private

Definition at line 420 of file _flow_graph_impl.h.

own_context

bool tbb::flow::interface10::graph::own_context

private

Definition at line 412 of file _flow_graph_impl.h.

Referenced by graph().

---

The documentation for this class was generated from the following files:

• _flow_graph_impl.h
• flow_graph.h