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 threadpool.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_threadpool_h_ #define _terimber_threadpool_h_ #include "base/map.h" #include "threadpool/thread.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) class client_thread_info { public: client_thread_info() : _ident(0), _data(0), _client(0), _wasted_calls(0), _obj(0) { } client_thread_info(thread* obj, size_t ident, void* data, terimber_thread_employer* client ) : _ident(ident), _data(data), _client(client), _wasted_calls(0), _obj(obj) { } size_t _ident; void* _data; terimber_thread_employer* _client; size_t _wasted_calls; thread* _obj; }; class threadpool : public terimber_threadpool, public terimber_thread_employer { typedef base_map< size_t, client_thread_info > ident_info_node_t; typedef node_allocator< ident_info_node_t::_node > ident_info_map_all_t; typedef _map< size_t, client_thread_info, ident_info_map_all_t > ident_info_map_t; typedef map< terimber_thread_employer*, ident_info_map_t > client_info_map_t; typedef list< client_thread_info > queue_info_t; public: threadpool( size_t capacity, size_t deactivate_time_msec ); ~threadpool(); virtual bool borrow_thread( size_t ident, void* data, terimber_thread_employer* client, size_t stay_on_alert_time_msec ); virtual bool borrow_from_range(size_t from, size_t to, void* data, terimber_thread_employer* client, size_t stay_on_alert_time_msec ); virtual void revoke_client( terimber_thread_employer* client ); virtual void doxray(); bool on(); void off(); protected: virtual bool v_has_job( size_t ident, void* user_data ); virtual void v_do_job( size_t ident, void* user_data ); private: bool _validate_client(size_t ident, terimber_thread_employer* client, client_info_map_t::iterator& it_client, ident_info_map_t::iterator& it_info ); void _clean_up_clients(terimber_thread_employer* client ); private: bool _on; size_t _capacity; size_t _thread_in_use; thread _housekeeper; thread_pool_t _thread_pool; queue_info_t _dispose_queue; client_info_map_t _clients_map; ident_info_map_all_t _map_allocator; mutex _clients_mtx; size_t _deactivate_time_msec; }; #pragma pack() END_TERIMBER_NAMESPACE #endif

© Copyright Terimber 2003-.