stdext::threads::thread_group Class Reference

Public Member Functions
	thread_group ()
	~thread_group () _NOEXCEPT
template<class _Func >
thread *	create_thread (_Func _Fp)
void	add_thread (thread *_Thrd)
void	remove_thread (thread *_Thrd)
void	join_all ()

Private Member Functions
	thread_group (const thread_group &)
thread_group &	operator= (const thread_group &)

Static Private Member Functions
static void	destroy (thread *_Thrd)
static void	join (thread *_Thrd)

Private Attributes
mutex	_Mtx
_STD vector< thread * >	_Elts

Constructor & Destructor Documentation

stdext::threads::thread_group::thread_group ( )

inline

        {   // construct
        }

stdext::threads::thread_group::~thread_group ( )

inline

        {   // destroy all owned threads
        _STD vector<thread *>::iterator _Next = _Elts.begin();
        _STD vector<thread *>::iterator _End = _Elts.end();
        for (; _Next != _End; ++_Next)
            destroy(*_Next);
        }

stdext::threads::thread_group::thread_group ( const thread_group &  )

private

Member Function Documentation

void stdext::threads::thread_group::add_thread ( thread *  _Thrd )

inline

        {   // add a thread
        _THREAD_ASSERT(_Thrd->_Joinable,
            "threads::thread_group::add_thread called "
                "with non-joinable thread");
        mutex::scoped_lock lock(_Mtx);
        if (_STD find(_Elts.begin(), _Elts.end(), _Thrd) == _Elts.end())
            _Elts.push_back(_Thrd);
        }

template<class _Func >

thread* stdext::threads::thread_group::create_thread ( _Func  _Fp )

inline

        {   // create a new thread
        thread *_Thr = 0;

 #if _HAS_EXCEPTIONS
        try {   // don't let exceptions escape
            _Thr = new thread(_Fp);
            add_thread(_Thr);
            }
        catch (...)
            {   // delete incomplete thread
            delete _Thr;
            throw;
            }

 #else /* _HAS_EXCEPTIONS */
        _Thr = new thread(_Fp);
        add_thread(_Thr);
 #endif /* _HAS_EXCEPTIONS */

        return (_Thr);
        }

static void stdext::threads::thread_group::destroy ( thread *  _Thrd )

inlinestaticprivate

        {   // delete a pointer to thread
        delete _Thrd;
        }

static void stdext::threads::thread_group::join ( thread *  _Thrd )

inlinestaticprivate

        {   // join a thread
        _Thrd->join();
        }

void stdext::threads::thread_group::join_all ( )

inline

        {   // join all threads
        mutex::scoped_lock lock(_Mtx);
        _STD vector<thread *>::iterator _Next = _Elts.begin();
        _STD vector<thread *>::iterator _End = _Elts.end();
        for (; _Next != _End; ++_Next)
            join(*_Next);
        }

thread_group& stdext::threads::thread_group::operator= ( const thread_group &  )

private

void stdext::threads::thread_group::remove_thread ( thread *  _Thrd )

inline

        {   // remove a thread
        mutex::scoped_lock lock(_Mtx);
        _Elts.erase(_STD find(_Elts.begin(), _Elts.end(), _Thrd));
        }

Member Data Documentation

_STD vector<thread *> stdext::threads::thread_group::_Elts

private

mutex stdext::threads::thread_group::_Mtx

private

---

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

• VS2013/inc/thr/thread