#ifndef BOOST_THREAD_PTHREAD_CONDITION_VARIABLE_FWD_HPP #define BOOST_THREAD_PTHREAD_CONDITION_VARIABLE_FWD_HPP // 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) // (C) Copyright 2007-8 Anthony Williams #include #include #include #include #include #include #include namespace boost { class condition_variable { private: pthread_cond_t cond; condition_variable(condition_variable&); condition_variable& operator=(condition_variable&); public: condition_variable() { int const res=pthread_cond_init(&cond,NULL); if(res) { throw thread_resource_error(); } } ~condition_variable() { BOOST_VERIFY(!pthread_cond_destroy(&cond)); } void wait(unique_lock& m); template void wait(unique_lock& m,predicate_type pred) { while(!pred()) wait(m); } bool timed_wait(unique_lock& m,boost::system_time const& wait_until); bool timed_wait(unique_lock& m,xtime const& wait_until) { return timed_wait(m,system_time(wait_until)); } template bool timed_wait(unique_lock& m,duration_type const& wait_duration) { return timed_wait(m,get_system_time()+wait_duration); } template bool timed_wait(unique_lock& m,boost::system_time const& wait_until,predicate_type pred) { while (!pred()) { if(!timed_wait(m, wait_until)) return pred(); } return true; } template bool timed_wait(unique_lock& m,xtime const& wait_until,predicate_type pred) { return timed_wait(m,system_time(wait_until),pred); } template bool timed_wait(unique_lock& m,duration_type const& wait_duration,predicate_type pred) { return timed_wait(m,get_system_time()+wait_duration,pred); } typedef pthread_cond_t* native_handle_type; native_handle_type native_handle() { return &cond; } void notify_one(); void notify_all(); }; } #include #endif