class server
          : private boost::noncopyable
        {
          multi_threading::thread_pool<multi_threading::pthread_thread_pool_impl<std::function<void()>,multi_threading::detail::pthread_sign_type_handler<SIGPIPE> >  > pool_connections_;
        };
    template<size_t... sign>
        struct pthread_sign_type
        {
            pthread_sign_type()
            {
                sigemptyset (&signal_mask);
                common::mpl::utils::repiter{(sigaddset(&signal_mask,sign),1)...};
                pthread_sigmask(SIG_SETMASK, &signal_mask, &old_mask);
            }
            sigset_t signal_mask;
            sigset_t old_mask;
        };
        template<size_t... sign>
        struct pthread_sign_handler_type : pthread_sign_type<sign...>
        {
            typedef pthread_sign_type<sign...> base_class;
            typedef pthread_sign_handler_type<sign...> class_type;
            pthread_sign_handler_type()
            {
                pthread_create(&thread,NULL,class_type::signal_thread, (void*)this);
            }
         private:
            static void *signal_thread (void *arg)
            {
                class_type *th = reinterpret_cast<class_type*>(arg);
                int       sig_caught;
                int       rc;
                while(1)
                {
                    rc = sigwait (&th->signal_mask, &sig_caught);
                    //сюда никогда не попадаю хотя очень хочется
                }
            }
            pthread_t thread;
        };
template<typename task_t,class pthread_sign_t = detail::empty >
    class pthread_thread_pool_impl: pthread_sign_t
    {
    public:
        typedef task_t task_type;
        typedef void (*signal_handler_func_type)(void *);
        pthread_thread_pool_impl(size_t threads): stop_(false)
        {
            pthread_attr_init(&attr);
            pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
            init_work(threads);
        }
        static void *thread_func(void *d)   { ((pthread_thread_pool_impl *)d)->run_work(); }
        ~pthread_thread_pool_impl()
        {
        }
    private:
        void init_work(size_t threads)
        {
            workers.clear();
            tasks.clear();
            for(size_t i = 0;i<threads;++i)
            {
                pthread_t thread;
                pthread_create(&thread, &attr,pthread_thread_pool_impl::thread_func, (void*)this);
                workers.push_back(thread);
            }
        }
        void run_work()
        {
              task_type task;
              while(true)
              {
              }
              pthread_exit(NULL);
        }
        pthread_attr_t attr;
        std::vector<pthread_t> workers;
    };

signal(SIGPIPE, SIG_IGN);

void run_work()
        {
signal(SIGPIPE, handler_func);
              task_type task;
              while(true)
              {
              }
              pthread_exit(NULL);
        }

void run_work()
        {
signal(SIGPIPE, handler_func);
              task_type task;
              while(true)
              {
              }
              pthread_exit(NULL);
        }