asio::detail::task_io_service< Task > Class Template Reference

#include <task_io_service.hpp>

Inheritance diagram for asio::detail::task_io_service< Task >:

asio::detail::service_base< Type > asio::io_service::service

List of all members.

Public Member Functions

 task_io_service (asio::io_service &io_service)
void init (size_t)
void shutdown_service ()
 Destroy all user-defined handler objects owned by the service.
size_t run (asio::error_code &ec)
size_t run_one (asio::error_code &ec)
size_t poll (asio::error_code &ec)
size_t poll_one (asio::error_code &ec)
void stop ()
void reset ()
void work_started ()
void work_finished ()
template<typename Handler>
void dispatch (Handler handler)
template<typename Handler>
void post (Handler handler)

Private Member Functions

size_t do_one (asio::detail::mutex::scoped_lock &lock, idle_thread_info *this_idle_thread, asio::error_code &ec)
void stop_all_threads ()
bool interrupt_one_idle_thread ()
void interrupt_all_idle_threads ()

Private Attributes

asio::detail::mutex mutex_
Task & task_
asio::detail::task_io_service::task_handler task_handler_
int outstanding_work_
handler_base * handler_queue_
handler_base * handler_queue_end_
bool stopped_
bool shutdown_
idle_thread_info * first_idle_thread_

Friends

class task_cleanup
class handler_cleanup

Classes

class  handler_base
class  handler_cleanup
class  handler_wrapper
struct  idle_thread_info
class  task_cleanup
class  task_handler

Detailed Description

template<typename Task>
class asio::detail::task_io_service< Task >

Definition at line 34 of file task_io_service.hpp.

Constructor & Destructor Documentation

template<typename Task>
asio::detail::task_io_service< Task >::task_io_service ( asio::io_service &  io_service  )  [inline]

Definition at line 39 of file task_io_service.hpp.

Member Function Documentation

template<typename Task>
void asio::detail::task_io_service< Task >::init ( size_t   )  [inline]

Definition at line 52 of file task_io_service.hpp.

Referenced by asio::io_service::io_service().

template<typename Task>
void asio::detail::task_io_service< Task >::shutdown_service (  )  [inline, virtual]

Destroy all user-defined handler objects owned by the service.

Implements asio::io_service::service.

Definition at line 57 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::handler_base::destroy(), simple_client::h, asio::detail::task_io_service< Task >::handler_queue_, asio::detail::task_io_service< Task >::handler_queue_end_, asio::detail::task_io_service< Task >::mutex_, asio::detail::task_io_service< Task >::handler_base::next_, asio::detail::task_io_service< Task >::shutdown_, asio::detail::task_io_service< Task >::task_handler_, and asio::detail::scoped_lock< Mutex >::unlock().

template<typename Task>
size_t asio::detail::task_io_service< Task >::run ( asio::error_code &  ec  )  [inline]

Definition at line 78 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::mutex_, n, asio::detail::task_io_service< Task >::idle_thread_info::next, and asio::detail::task_io_service< Task >::idle_thread_info::prev.

Referenced by asio::io_service::run().

template<typename Task>
size_t asio::detail::task_io_service< Task >::run_one ( asio::error_code &  ec  )  [inline]

Definition at line 96 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::mutex_, asio::detail::task_io_service< Task >::idle_thread_info::next, and asio::detail::task_io_service< Task >::idle_thread_info::prev.

Referenced by asio::io_service::run_one().

template<typename Task>
size_t asio::detail::task_io_service< Task >::poll ( asio::error_code &  ec  )  [inline]

Definition at line 110 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::mutex_, and n.

Referenced by asio::io_service::poll().

template<typename Task>
size_t asio::detail::task_io_service< Task >::poll_one ( asio::error_code &  ec  )  [inline]

Definition at line 124 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::do_one(), and asio::detail::task_io_service< Task >::mutex_.

Referenced by asio::io_service::poll_one().

template<typename Task>
void asio::detail::task_io_service< Task >::stop (  )  [inline]

Definition at line 134 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::mutex_, and asio::detail::task_io_service< Task >::stop_all_threads().

Referenced by asio::io_service::stop().

template<typename Task>
void asio::detail::task_io_service< Task >::reset (  )  [inline]

Definition at line 141 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::mutex_, and asio::detail::task_io_service< Task >::stopped_.

Referenced by asio::io_service::reset().

template<typename Task>
void asio::detail::task_io_service< Task >::work_started (  )  [inline]

Definition at line 148 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::mutex_, and asio::detail::task_io_service< Task >::outstanding_work_.

Referenced by asio::io_service::work::work().

template<typename Task>
void asio::detail::task_io_service< Task >::work_finished (  )  [inline]

Definition at line 155 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::mutex_, asio::detail::task_io_service< Task >::outstanding_work_, and asio::detail::task_io_service< Task >::stop_all_threads().

Referenced by asio::io_service::work::~work().

template<typename Task>
template<typename Handler>
void asio::detail::task_io_service< Task >::dispatch ( Handler  handler  )  [inline]

Definition at line 164 of file task_io_service.hpp.

References asio_handler_invoke_helpers::invoke(), and asio::detail::task_io_service< Task >::post().

Referenced by asio::io_service::dispatch().

template<typename Task>
template<typename Handler>
void asio::detail::task_io_service< Task >::post ( Handler  handler  )  [inline]

Definition at line 174 of file task_io_service.hpp.

References asio::detail::handler_ptr< Alloc_Traits >::get(), asio::detail::task_io_service< Task >::handler_queue_, asio::detail::task_io_service< Task >::handler_queue_end_, asio::detail::task_io_service< Task >::interrupt_one_idle_thread(), asio::detail::task_io_service< Task >::mutex_, asio::detail::task_io_service< Task >::handler_base::next_, asio::detail::task_io_service< Task >::outstanding_work_, asio::detail::handler_ptr< Alloc_Traits >::release(), asio::detail::task_io_service< Task >::shutdown_, asio::detail::task_io_service< Task >::task_, and asio::detail::task_io_service< Task >::task_handler_.

Referenced by asio::detail::task_io_service< Task >::dispatch(), and asio::io_service::post().

template<typename Task>
size_t asio::detail::task_io_service< Task >::do_one ( asio::detail::mutex::scoped_lock &  lock,
idle_thread_info *  this_idle_thread,
asio::error_code &  ec 
) [inline, private]

Definition at line 212 of file task_io_service.hpp.

References c, asio::detail::task_io_service< Task >::handler_base::call(), asio::detail::null_event::clear(), asio::detail::task_io_service< Task >::first_idle_thread_, simple_client::h, asio::detail::task_io_service< Task >::handler_queue_, asio::detail::task_io_service< Task >::handler_queue_end_, asio::detail::scoped_lock< Mutex >::lock(), asio::detail::task_io_service< Task >::idle_thread_info::next, asio::detail::task_io_service< Task >::handler_base::next_, asio::detail::task_io_service< Task >::outstanding_work_, asio::detail::task_io_service< Task >::idle_thread_info::prev, asio::detail::task_io_service< Task >::stop_all_threads(), asio::detail::task_io_service< Task >::stopped_, asio::detail::task_io_service< Task >::task_, asio::detail::task_io_service< Task >::task_handler_, asio::detail::scoped_lock< Mutex >::unlock(), asio::detail::null_event::wait(), and asio::detail::task_io_service< Task >::idle_thread_info::wakeup_event.

Referenced by asio::detail::task_io_service< Task >::poll(), asio::detail::task_io_service< Task >::poll_one(), asio::detail::task_io_service< Task >::run(), and asio::detail::task_io_service< Task >::run_one().

template<typename Task>
void asio::detail::task_io_service< Task >::stop_all_threads (  )  [inline, private]

Definition at line 305 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::handler_queue_end_, asio::detail::task_io_service< Task >::interrupt_all_idle_threads(), asio::detail::task_io_service< Task >::stopped_, asio::detail::task_io_service< Task >::task_, and asio::detail::task_io_service< Task >::task_handler_.

Referenced by asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::stop(), asio::detail::task_io_service< Task >::work_finished(), and asio::detail::task_io_service< Task >::handler_cleanup::~handler_cleanup().

template<typename Task>
bool asio::detail::task_io_service< Task >::interrupt_one_idle_thread (  )  [inline, private]

Definition at line 315 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::first_idle_thread_, asio::detail::task_io_service< Task >::idle_thread_info::next, asio::detail::null_event::signal(), and asio::detail::task_io_service< Task >::idle_thread_info::wakeup_event.

Referenced by asio::detail::task_io_service< Task >::post().

template<typename Task>
void asio::detail::task_io_service< Task >::interrupt_all_idle_threads (  )  [inline, private]

Definition at line 327 of file task_io_service.hpp.

References asio::detail::task_io_service< Task >::first_idle_thread_, asio::detail::task_io_service< Task >::idle_thread_info::next, asio::detail::null_event::signal(), and asio::detail::task_io_service< Task >::idle_thread_info::wakeup_event.

Referenced by asio::detail::task_io_service< Task >::stop_all_threads().

Friends And Related Function Documentation

template<typename Task>
friend class task_cleanup [friend]

Definition at line 341 of file task_io_service.hpp.

template<typename Task>
friend class handler_cleanup [friend]

Definition at line 465 of file task_io_service.hpp.

Member Data Documentation

template<typename Task>
asio::detail::mutex asio::detail::task_io_service< Task >::mutex_ [private]

Definition at line 490 of file task_io_service.hpp.

Referenced by asio::detail::task_io_service< Task >::poll(), asio::detail::task_io_service< Task >::poll_one(), asio::detail::task_io_service< Task >::post(), asio::detail::task_io_service< Task >::reset(), asio::detail::task_io_service< Task >::run(), asio::detail::task_io_service< Task >::run_one(), asio::detail::task_io_service< Task >::shutdown_service(), asio::detail::task_io_service< Task >::stop(), asio::detail::task_io_service< Task >::work_finished(), and asio::detail::task_io_service< Task >::work_started().

template<typename Task>
Task& asio::detail::task_io_service< Task >::task_ [private]

Definition at line 493 of file task_io_service.hpp.

Referenced by asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::post(), and asio::detail::task_io_service< Task >::stop_all_threads().

template<typename Task>
asio::detail::task_io_service::task_handler asio::detail::task_io_service< Task >::task_handler_ [private]

Referenced by asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::post(), asio::detail::task_io_service< Task >::shutdown_service(), asio::detail::task_io_service< Task >::stop_all_threads(), and asio::detail::task_io_service< Task >::task_cleanup::~task_cleanup().

template<typename Task>
int asio::detail::task_io_service< Task >::outstanding_work_ [private]

Definition at line 507 of file task_io_service.hpp.

Referenced by asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::post(), asio::detail::task_io_service< Task >::work_finished(), asio::detail::task_io_service< Task >::work_started(), and asio::detail::task_io_service< Task >::handler_cleanup::~handler_cleanup().

template<typename Task>
handler_base* asio::detail::task_io_service< Task >::handler_queue_ [private]

Definition at line 510 of file task_io_service.hpp.

Referenced by asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::post(), asio::detail::task_io_service< Task >::shutdown_service(), and asio::detail::task_io_service< Task >::task_cleanup::~task_cleanup().

template<typename Task>
handler_base* asio::detail::task_io_service< Task >::handler_queue_end_ [private]

Definition at line 513 of file task_io_service.hpp.

Referenced by asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::post(), asio::detail::task_io_service< Task >::shutdown_service(), asio::detail::task_io_service< Task >::stop_all_threads(), and asio::detail::task_io_service< Task >::task_cleanup::~task_cleanup().

template<typename Task>
bool asio::detail::task_io_service< Task >::stopped_ [private]

Definition at line 516 of file task_io_service.hpp.

Referenced by asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::reset(), and asio::detail::task_io_service< Task >::stop_all_threads().

template<typename Task>
bool asio::detail::task_io_service< Task >::shutdown_ [private]

Definition at line 519 of file task_io_service.hpp.

Referenced by asio::detail::task_io_service< Task >::post(), and asio::detail::task_io_service< Task >::shutdown_service().

template<typename Task>
idle_thread_info* asio::detail::task_io_service< Task >::first_idle_thread_ [private]

Definition at line 530 of file task_io_service.hpp.

Referenced by asio::detail::task_io_service< Task >::do_one(), asio::detail::task_io_service< Task >::interrupt_all_idle_threads(), and asio::detail::task_io_service< Task >::interrupt_one_idle_thread().

The documentation for this class was generated from the following file:
Generated on Sun May 25 00:21:33 2008 by  doxygen 1.5.6