Function threadproc1

dlib/test/pipe.cpp:56–87

            typename pipe
            >
        void threadproc1 (
            void* param
        )
        {
            add_running_thread();
            pipe& p = *static_cast<pipe*>(param);
            try
            {

                int last = -1;
                for (unsigned long i = 0; i < proc1_count; ++i)
                {
                    int cur=0;
                    DLIB_TEST(p.dequeue(cur) == true);
                    DLIB_TEST(last + 1 == cur);
                    last = cur;
                }
                DLIB_TEST(p.size() == 0);
            }
            catch(exception& e)
            {
                auto_mutex M(m);
                found_error = true;
                cout << "\n\nERRORS FOUND" << endl;
                cout << e.what() << endl;
                dlog << LWARN << "ERRORS FOUND";
                dlog << LWARN << e.what();
                p.disable();
            }        

            remove_running_thread();
        }


        template <