123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188 |
- #ifndef BOOST_SMART_PTR_DETAIL_LIGHTWEIGHT_THREAD_HPP_INCLUDED
- #define BOOST_SMART_PTR_DETAIL_LIGHTWEIGHT_THREAD_HPP_INCLUDED
- // MS compatible compilers support #pragma once
- #if defined(_MSC_VER) && (_MSC_VER >= 1020)
- # pragma once
- #endif
- // boost/detail/lightweight_thread.hpp
- //
- // Copyright (c) 2002 Peter Dimov and Multi Media Ltd.
- // Copyright (c) 2008, 2018 Peter Dimov
- //
- // Distributed under the Boost Software License, Version 1.0.
- // See accompanying file LICENSE_1_0.txt or copy at
- // http://www.boost.org/LICENSE_1_0.txt
- //
- //
- // typedef /*...*/ lw_thread_t; // as pthread_t
- // template<class F> int lw_thread_create( lw_thread_t & th, F f );
- // void lw_thread_join( lw_thread_t th );
- #include <boost/config.hpp>
- #include <memory>
- #include <cerrno>
- #if defined( BOOST_HAS_PTHREADS )
- #include <pthread.h>
- namespace boost
- {
- namespace detail
- {
- typedef ::pthread_t lw_thread_t;
- inline int lw_thread_create_( lw_thread_t* thread, const pthread_attr_t* attr, void* (*start_routine)( void* ), void* arg )
- {
- return ::pthread_create( thread, attr, start_routine, arg );
- }
- inline void lw_thread_join( lw_thread_t th )
- {
- ::pthread_join( th, 0 );
- }
- } // namespace detail
- } // namespace boost
- #else // defined( BOOST_HAS_PTHREADS )
- #include <windows.h>
- #include <process.h>
- namespace boost
- {
- namespace detail
- {
- typedef HANDLE lw_thread_t;
- inline int lw_thread_create_( lw_thread_t * thread, void const *, unsigned (__stdcall * start_routine) (void*), void* arg )
- {
- HANDLE h = (HANDLE)_beginthreadex( 0, 0, start_routine, arg, 0, 0 );
- if( h != 0 )
- {
- *thread = h;
- return 0;
- }
- else
- {
- return EAGAIN;
- }
- }
- inline void lw_thread_join( lw_thread_t thread )
- {
- ::WaitForSingleObject( thread, INFINITE );
- ::CloseHandle( thread );
- }
- } // namespace detail
- } // namespace boost
- #endif // defined( BOOST_HAS_PTHREADS )
- namespace boost
- {
- namespace detail
- {
- class lw_abstract_thread
- {
- public:
- virtual ~lw_abstract_thread() {}
- virtual void run() = 0;
- };
- #if defined( BOOST_HAS_PTHREADS )
- extern "C" void * lw_thread_routine( void * pv )
- {
- #if defined(BOOST_NO_CXX11_SMART_PTR)
- std::auto_ptr<lw_abstract_thread> pt( static_cast<lw_abstract_thread *>( pv ) );
- #else
- std::unique_ptr<lw_abstract_thread> pt( static_cast<lw_abstract_thread *>( pv ) );
- #endif
- pt->run();
- return 0;
- }
- #else
- unsigned __stdcall lw_thread_routine( void * pv )
- {
- #if defined(BOOST_NO_CXX11_SMART_PTR)
- std::auto_ptr<lw_abstract_thread> pt( static_cast<lw_abstract_thread *>( pv ) );
- #else
- std::unique_ptr<lw_abstract_thread> pt( static_cast<lw_abstract_thread *>( pv ) );
- #endif
- pt->run();
- return 0;
- }
- #endif
- template<class F> class lw_thread_impl: public lw_abstract_thread
- {
- public:
- explicit lw_thread_impl( F f ): f_( f )
- {
- }
- void run()
- {
- f_();
- }
- private:
- F f_;
- };
- template<class F> int lw_thread_create( lw_thread_t & th, F f )
- {
- #if defined(BOOST_NO_CXX11_SMART_PTR)
- std::auto_ptr<lw_abstract_thread> p( new lw_thread_impl<F>( f ) );
- #else
- std::unique_ptr<lw_abstract_thread> p( new lw_thread_impl<F>( f ) );
- #endif
- int r = lw_thread_create_( &th, 0, lw_thread_routine, p.get() );
- if( r == 0 )
- {
- p.release();
- }
- return r;
- }
- } // namespace detail
- } // namespace boost
- #endif // #ifndef BOOST_SMART_PTR_DETAIL_LIGHTWEIGHT_THREAD_HPP_INCLUDED
|