+class Msg_Thread::Private {
+public:
+ int m_no_threads;
+ Msg_Thread_Queue m_input;
+ Msg_Thread_Queue m_output;
+#if YAZ_POSIX_THREADS
+ int m_fd[2];
+ yazpp_1::ISocketObservable *m_SocketObservable;
+ pthread_t *m_thread_id;
+ pthread_mutex_t m_mutex_input_data;
+ pthread_cond_t m_cond_input_data;
+ pthread_mutex_t m_mutex_output_data;
+ bool m_stop_flag;
+#endif
+};
+