Subject: [Boost-commit] svn:boost r51445 - sandbox/threadpool/boost/tp
From: oliver.kowalke_at_[hidden]
Date: 2009-02-25 14:46:51
Author: olli
Date: 2009-02-25 14:46:51 EST (Wed, 25 Feb 2009)
New Revision: 51445
URL: http://svn.boost.org/trac/boost/changeset/51445
Log:
* wait_for_all() added
Text files modified:
sandbox/threadpool/boost/tp/task.hpp | 174 ++++++++++++++++++++++++++++++++++++++++
1 files changed, 174 insertions(+), 0 deletions(-)
Modified: sandbox/threadpool/boost/tp/task.hpp
==============================================================================
--- sandbox/threadpool/boost/tp/task.hpp (original)
+++ sandbox/threadpool/boost/tp/task.hpp 2009-02-25 14:46:51 EST (Wed, 25 Feb 2009)
@@ -16,6 +16,59 @@
class task
{
private:
+ template<
+ typename T1,
+ typename T2
+ >
+ friend void wait_for_any( T1 &, T2 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3
+ >
+ friend void wait_for_any( T1 &, T2 &, T3 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4
+ >
+ friend void wait_for_any( T1 &, T2 &, T3 &, T4 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4,
+ typename T5
+ >
+ friend void wait_for_any( T1 &, T2 &, T3 &, T4 &, T5 &);
+ template<
+ typename T1,
+ typename T2
+ >
+ friend void wait_for_all( T1 &, T2 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3
+ >
+ friend void wait_for_all( T1 &, T2 &, T3 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4
+ >
+ friend void wait_for_all( T1 &, T2 &, T3 &, T4 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4,
+ typename T5
+ >
+ friend void wait_for_all( T1 &, T2 &, T3 &, T4 &, T5 &);
+
jss::shared_future< R > fut_;
detail::interrupter intr_;
@@ -71,6 +124,59 @@
class task< void >
{
private:
+ template<
+ typename T1,
+ typename T2
+ >
+ friend void wait_for_any( T1 &, T2 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3
+ >
+ friend void wait_for_any( T1 &, T2 &, T3 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4
+ >
+ friend void wait_for_any( T1 &, T2 &, T3 &, T4 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4,
+ typename T5
+ >
+ friend void wait_for_any( T1 &, T2 &, T3 &, T4 &, T5 &);
+ template<
+ typename T1,
+ typename T2
+ >
+ friend void wait_for_all( T1 &, T2 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3
+ >
+ friend void wait_for_all( T1 &, T2 &, T3 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4
+ >
+ friend void wait_for_all( T1 &, T2 &, T3 &, T4 &);
+ template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4,
+ typename T5
+ >
+ friend void wait_for_all( T1 &, T2 &, T3 &, T4 &, T5 &);
+
jss::shared_future< void > fut_;
detail::interrupter intr_;
@@ -121,6 +227,74 @@
bool timed_wait_until( system_time const& abs_time) const
{ return fut_.timed_wait_until( abs_time); }
};
+
+template<
+ typename T1,
+ typename T2
+>
+void wait_for_all( T1 & t1, T2 & t2)
+{ jss::wait_for_all( t1.fut_, t2.fut_); };
+
+template<
+ typename T1,
+ typename T2,
+ typename T3
+>
+void wait_for_all( T1 & t1, T2 & t2, T3 & t3)
+{ jss::wait_for_all( t1.fut_, t2.fut_, t3.fut_); };
+
+template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4
+>
+void wait_for_all( T1 & t1, T2 & t2, T3 & t3, T4 & t4)
+{ jss::wait_for_all( t1.fut_, t2.fut_, t3.fut_, t4.fut_); };
+
+template<
+ typename T1,
+ typename T2,
+ typename T3,
+ typename T4,
+ typename T5
+>
+void wait_for_all( T1 & t1, T2 & t2, T3 & t3, T4 & t4, T5 & t5)
+{ jss::wait_for_all( t1.fut_, t2.fut_, t3.fut_, t4.fut_, t5.fut_); };
+
+// template<
+// typename T1,
+// typename T2
+// >
+// void wait_for_any( T1 & t1, T2 & t2)
+// { jss::wait_for_any( t1.fut_, t2.fut_); };
+//
+// template<
+// typename T1,
+// typename T2,
+// typename T3
+// >
+// void wait_for_any( T1 & t1, T2 & t2, T3 & t3)
+// { jss::wait_for_any( t1.fut_, t2.fut_, t3.fut_); };
+//
+// template<
+// typename T1,
+// typename T2,
+// typename T3,
+// typename T4
+// >
+// void wait_for_any( T1 & t1, T2 & t2, T3 & t3, T4 & t4)
+// { jss::wait_for_any( t1.fut_, t2.fut_, t3.fut_, t4.fut_); };
+//
+// template<
+// typename T1,
+// typename T2,
+// typename T3,
+// typename T4,
+// typename T5
+// >
+// void wait_for_any( T1 & t1, T2 & t2, T3 & t3, T4 & t4, T5 & t5)
+// { jss::wait_for_any( t1.fut_, t2.fut_, t3.fut_, t4.fut_, t5.fut_); };
} }
#endif // BOOST_TP_TASK_H