libjmmcg  release_579_6_g8cffd
A C++ library containing an eclectic mix of useful, advanced components.
pool_thread.hpp
Go to the documentation of this file.
1 /******************************************************************************
2 ** Copyright © 2004 by J.M.McGuiness, coder@hussar.me.uk
3 **
4 ** This library is free software; you can redistribute it and/or
5 ** modify it under the terms of the GNU Lesser General Public
6 ** License as published by the Free Software Foundation; either
7 ** version 2.1 of the License, or (at your option) any later version.
8 **
9 ** This library is distributed in the hope that it will be useful,
10 ** but WITHOUT ANY WARRANTY; without even the implied warranty of
11 ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 ** Lesser General Public License for more details.
13 **
14 ** You should have received a copy of the GNU Lesser General Public
15 ** License along with this library; if not, write to the Free Software
16 ** Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 */
18 
19 namespace jmmcg { namespace ppd { namespace pool { namespace thread_types {
20 
21  template<class WQ>
22  class steal<generic_traits::return_data::nonjoinable, thread_os_traits<generic_traits::MS_Win32, sequential_mode>, WQ> : public pool_thread<thread_os_traits<generic_traits::MS_Win32, sequential_mode>, typename WQ::have_work_type::atomic_t>, protected non_assignable {
23  public:
24  typedef pool_thread<thread_os_traits<generic_traits::MS_Win32, sequential_mode>, typename WQ::have_work_type::atomic_t> base_t;
25  typedef typename base_t::os_traits os_traits;
26  typedef typename os_traits::thread_traits::model_type model_type;
27  typedef typename os_traits::lock_traits lock_traits;
28  typedef typename os_traits::thread_traits thread_traits;
29  typedef batch_details<WQ> batch_type;
30  typedef typename batch_type::signalled_work_queue_type signalled_work_queue_type;
31  typedef typename base_t::exit_requested_type exit_requested_type;
32 
33  __stdcall steal(exit_requested_type &, signalled_work_queue_type &) noexcept(true) {}
34 
35  private:
36  typename thread_traits::api_params_type::states __fastcall execute() {
37  return thread_traits::api_params_type::no_kernel_thread;
38  }
39  };
40 
41  template<class WQ>
42  class steal<generic_traits::return_data::nonjoinable, thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, WQ>
43  : public pool_thread<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, typename WQ::have_work_type::atomic_t>, protected non_assignable {
44  public:
45  typedef pool_thread<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, typename WQ::have_work_type::atomic_t> base_t;
46  typedef typename base_t::os_traits os_traits;
47  typedef typename os_traits::thread_traits::model_type model_type;
48  typedef typename os_traits::lock_traits lock_traits;
49  typedef typename os_traits::thread_traits thread_traits;
50  typedef batch_details<WQ> batch_type;
51  typedef typename batch_type::signalled_work_queue_type signalled_work_queue_type;
52  typedef typename base_t::exit_requested_type exit_requested_type;
53 
54  __stdcall steal(exit_requested_type &exit_requested, signalled_work_queue_type &signalled_work_queue) noexcept(true);
55  ~steal() noexcept(true);
56 
57  void __fastcall process_a_batch(typename os_traits::thread_exception const &exception_thrown_in_thread) {
58  batch.process_a_batch(exception_thrown_in_thread, signalled_work_queue);
59  }
60 
61  private:
62  batch_type batch;
63  signalled_work_queue_type &signalled_work_queue;
64 
65  typename thread_traits::api_params_type::states __fastcall process() noexcept(false);
66  };
67 
68  template<class WQ>
69  class slave<generic_traits::return_data::nonjoinable, thread_os_traits<generic_traits::MS_Win32, sequential_mode>, WQ>
70  : public pool_thread<thread_os_traits<generic_traits::MS_Win32, sequential_mode>, typename WQ::have_work_type::atomic_t>, public sp_counter_type<thread_os_traits<generic_traits::MS_Win32, sequential_mode>::lock_traits>, protected non_assignable {
71  public:
72  typedef pool_thread<thread_os_traits<generic_traits::MS_Win32, sequential_mode>, typename WQ::have_work_type::atomic_t> base_t;
73  typedef typename base_t::os_traits os_traits;
74  typedef typename os_traits::thread_traits::model_type model_type;
75  typedef typename os_traits::lock_traits lock_traits;
76  typedef typename os_traits::thread_traits thread_traits;
77  typedef WQ signalled_work_queue_type;
78  typedef typename base_t::exit_requested_type exit_requested_type;
79 
80  __stdcall slave(exit_requested_type &exit_requested, typename signalled_work_queue_type::value_type &) noexcept(true)
81  : base_t(exit_requested) {
82  }
83 
84  private:
85  typename thread_traits::api_params_type::states __fastcall process() noexcept(true) {
86  return thread_traits::api_params_type::no_kernel_thread;
87  }
88  };
89 
90  template<class WQ>
91  class slave<generic_traits::return_data::nonjoinable, thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, WQ>
92  : public pool_thread<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, typename WQ::have_work_type::atomic_t>, public sp_counter_type<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>::lock_traits>, protected non_assignable {
93  public:
94  typedef pool_thread<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, typename WQ::have_work_type::atomic_t> base_t;
95  typedef typename base_t::os_traits os_traits;
96  typedef typename os_traits::thread_traits::model_type model_type;
97  typedef typename os_traits::lock_traits lock_traits;
98  typedef typename os_traits::thread_traits thread_traits;
99  typedef WQ signalled_work_queue_type;
100  typedef typename base_t::exit_requested_type exit_requested_type;
101 
102  __stdcall slave(exit_requested_type &exit_requested, typename signalled_work_queue_type::value_type &wk) noexcept(true);
103  ~slave() noexcept(true);
104 
105  private:
106  typename signalled_work_queue_type::value_type some_work;
107 
108  typename thread_traits::api_params_type::states __fastcall process() noexcept(false);
109  };
110 
111  /// You can report back exceptions from this thread wrapper type. Oh - and make sure you construct the execution context too (because you get the exceptions through that type).
112  template<class WQ>
113  class steal<generic_traits::return_data::joinable, thread_os_traits<generic_traits::MS_Win32, sequential_mode>, WQ>
114  : public pool_thread<thread_os_traits<generic_traits::MS_Win32, sequential_mode>, typename WQ::have_work_type::atomic_t> {
115  public:
116  typedef pool_thread<thread_os_traits<generic_traits::MS_Win32, sequential_mode>, typename WQ::have_work_type::atomic_t> base_t;
117  typedef typename base_t::os_traits os_traits;
118  typedef typename os_traits::thread_traits::model_type model_type;
119  typedef typename os_traits::lock_traits lock_traits;
120  typedef typename os_traits::thread_traits thread_traits;
121  typedef WQ signalled_work_queue_type;
122  typedef typename base_t::exit_requested_type exit_requested_type;
123 
124  __stdcall steal(exit_requested_type &, signalled_work_queue_type &) noexcept(true) {}
125 
126  private:
127  typename thread_traits::api_params_type::states __fastcall process() noexcept(true) {
128  return thread_traits::api_params_type::no_kernel_thread;
129  }
130  };
131 
132  /// You can report back exceptions from this thread wrapper type. Oh - and make sure you construct the execution context too (because you get the exceptions through that type).
133  template<class WQ>
134  class steal<generic_traits::return_data::joinable, thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, WQ>
135  : public pool_thread<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, typename WQ::have_work_type::atomic_t>, public batch_details<WQ>, protected non_copyable {
136  public:
137  typedef pool_thread<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, typename WQ::have_work_type::atomic_t> base_t;
138  typedef typename base_t::os_traits os_traits;
139  typedef typename os_traits::thread_traits::model_type model_type;
140  typedef typename os_traits::lock_traits lock_traits;
141  typedef typename os_traits::thread_traits thread_traits;
142  typedef batch_details<WQ> batch_type;
143  typedef typename batch_type::signalled_work_queue_type signalled_work_queue_type;
144  typedef typename base_t::exit_requested_type exit_requested_type;
145 
146  __stdcall steal(exit_requested_type &, signalled_work_queue_type &) noexcept(true);
147  ~steal() noexcept(true);
148 
149  void __fastcall process_a_batch(typename os_traits::thread_exception const &exception_thrown_in_thread) {
150  batch.process_a_batch(exception_thrown_in_thread, signalled_work_queue);
151  }
152 
153  private:
154  batch_type batch;
155  signalled_work_queue_type &signalled_work_queue;
156 
157  typename thread_traits::api_params_type::states __fastcall process() noexcept(false);
158  };
159 
160  /**
161  \todo JMG: Looks like this needs completing, as some fns are undefined! Maybe not used...
162  */
163  template<class WQ>
164  class slave<generic_traits::return_data::joinable, thread_os_traits<generic_traits::MS_Win32, sequential_mode>, WQ>
165  : public pool_thread<thread_os_traits<generic_traits::MS_Win32, sequential_mode>, typename WQ::have_work_type::atomic_t>, public sp_counter_type<thread_os_traits<generic_traits::MS_Win32, sequential_mode>::lock_traits>, protected non_assignable {
166  public:
167  typedef pool_thread<thread_os_traits<generic_traits::MS_Win32, sequential_mode>, typename WQ::have_work_type::atomic_t> base_t;
168  typedef typename base_t::os_traits os_traits;
169  typedef typename os_traits::thread_traits::model_type model_type;
170  typedef typename os_traits::lock_traits lock_traits;
171  typedef typename os_traits::thread_traits thread_traits;
172  typedef WQ signalled_work_queue_type;
173  typedef typename base_t::exit_requested_type exit_requested_type;
174 
175  __stdcall slave(exit_requested_type &exit_requested, typename signalled_work_queue_type::value_type &wk) noexcept(true)
176  : base_t(exit_requested), some_work(wk) {
177  }
178 
179  private:
180  typename signalled_work_queue_type::value_type some_work;
181 
182  typename thread_traits::api_params_type::states __fastcall process() noexcept(true) {
183  return thread_traits::api_params_type::no_kernel_thread;
184  }
185  };
186 
187  template<class WQ>
188  class slave<generic_traits::return_data::joinable, thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, WQ>
189  : public pool_thread<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, typename WQ::have_work_type::atomic_t>, public sp_counter_type<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>::lock_traits>, protected non_assignable {
190  public:
191  typedef pool_thread<thread_os_traits<generic_traits::MS_Win32, heavyweight_threading>, typename WQ::have_work_type::atomic_t> base_t;
192  typedef typename base_t::os_traits os_traits;
193  typedef typename os_traits::thread_traits::model_type model_type;
194  typedef typename os_traits::lock_traits lock_traits;
195  typedef typename os_traits::thread_traits thread_traits;
196  typedef WQ signalled_work_queue_type;
197  typedef typename base_t::exit_requested_type exit_requested_type;
198 
199  __stdcall slave(exit_requested_type &exit_requested, typename signalled_work_queue_type::value_type &wk) noexcept(true);
200  ~slave() noexcept(true);
201 
202  private:
203  typename signalled_work_queue_type::value_type some_work;
204 
205  typename thread_traits::api_params_type::states __fastcall process() noexcept(false);
206  };
207 
208 } } } }
209 
210 #include "pool_thread_impl.hpp"