Thread portable class Gate portable class Timer class Pool class Terimber 2.0 About C++

Downloads Products & Services Support Clients Open Source About Home / Open source / Terimber 2.0 thread.h Go to the documentation of this file. /* * The Software License * ================================================================================= * Copyright (c) 2003-.The Terimber Corporation. All rights reserved. * ================================================================================= * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * The end-user documentation included with the redistribution, if any, * must include the following acknowledgment: * "This product includes software developed by the Terimber Corporation." * ================================================================================= * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED WARRANTIES, * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. * IN NO EVENT SHALL THE TERIMBER CORPORATION OR ITS CONTRIBUTORS BE LIABLE FOR * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * ================================================================================ */ #ifndef _terimber_thread_h_ #define _terimber_thread_h_ #include "base/template.h" #include "threadpool/threadpoolfactory.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) class job_task { public: job_task() : _employer(0), _ident(0), _timeout(INFINITE), _user_data(0) { } job_task( terimber_thread_employer* employer, size_t ident, size_t timeout, void* user_data ) : _employer(employer), _ident(ident), _timeout(timeout), _user_data(user_data) { } job_task(const job_task& x) { *this = x; } job_task& operator=(const job_task& x) { if (this != &x) { _employer = x._employer; _ident = x._ident; _timeout = x._timeout; _user_data = x._user_data; } return *this; } void clear() { _employer = 0; _ident = 0; _timeout = INFINITE; _user_data = 0; } terimber_thread_employer* _employer; size_t _ident; size_t _timeout; void* _user_data; }; enum thread_state { THREAD_CLOSE, THREAD_STARTING, THREAD_SLEEPING, THREAD_RUNNING, THREAD_STOPPING }; class thread { static #if OS_TYPE == OS_WIN32 unsigned int __stdcall #else void* #endif start_thread( void* data ); bool inside_thread() const; thread(const thread& x); thread& operator=(const thread& x); public: thread(); ~thread(); thread_state get_state() const; bool start(); bool assign_job( const job_task& job_task ); bool cancel_job(); bool stop(); void wakeup() const; private: bool change_state( thread_state new_state ); bool execute(); bool sleep(); private: job_task _job_task; mutex _mtx; event _ev_start; event _ev_wakeup; event _ev_end; mutex _mtx_job; thread_state _state; #if OS_TYPE == OS_WIN32 HANDLE #else pthread_t #endif _handle; }; class thread_creator : public proto_creator< thread_creator, thread, job_task > { public: static thread* create( const job_task& task ); static void activate( thread* obj, const job_task& task ); static void back( thread* obj, const job_task& task ); static void destroy( thread* obj, const job_task& task ); static void deactivate( thread* obj, const job_task& task ); }; typedef pool< thread_creator > thread_pool_t; #pragma pack() END_TERIMBER_NAMESPACE #endif // _terimber_thread_h_

© Copyright Terimber 2003-.