X-Git-Url: http://git.cinelerra-gg.org/git/?a=blobdiff_plain;f=cinelerra-5.1%2Fguicast%2Fthread.C;h=c2f3321d7987a28f85f90bf65b83078bb65cc72d;hb=20002b54e92573aafc97cbc3a85ec529b35bb191;hp=6cde612dfdfbb853902f02e423bc39699817bf18;hpb=21c2e6b36d6a96c2f662a89459d607b5a387f4eb;p=goodguy%2Fhistory.git diff --git a/cinelerra-5.1/guicast/thread.C b/cinelerra-5.1/guicast/thread.C index 6cde612d..c2f3321d 100644 --- a/cinelerra-5.1/guicast/thread.C +++ b/cinelerra-5.1/guicast/thread.C @@ -65,8 +65,8 @@ void* Thread::entrypoint(void *parameters) thread->run(); thread->finished = true; if( !thread->synchronous ) { - if( !thread->cancelled ) TheList::dbg_del(thread->tid); if( thread->autodelete ) delete thread; + else if( !thread->cancelled ) TheList::dbg_del(thread->tid); else thread->tid = ((pthread_t)-1); } return NULL; @@ -106,9 +106,13 @@ void Thread::start() perror("Thread::start pthread_attr_setinheritsched"); } +// autodelete may delete this immediately after create + int autodelete = this->autodelete; + pthread_create(&tid, &attr, Thread::entrypoint, this); - TheList::dbg_add(tid, owner, typeid(*this).name()); + if( !autodelete ) + TheList::dbg_add(tid, owner, typeid(*this).name()); } int Thread::cancel() @@ -127,9 +131,14 @@ int Thread::join() // join this thread { if( !exists() ) return 0; if( synchronous ) { -// NOTE: this does not do anything if the thread is not synchronous +// NOTE: this fails if the thread is not synchronous or +// or another thread is already waiting to join. int ret = pthread_join(tid, 0); - if( ret ) strerror(ret); + if( ret ) { + fflush(stdout); + fprintf(stderr, "Thread %p: %s\n", (void*)tid, strerror(ret)); + fflush(stderr); + } CLEAR_LOCKS_TID(tid); TheList::dbg_del(tid); tid = ((pthread_t)-1); @@ -141,7 +150,7 @@ int Thread::join() // join this thread while( running() && !cancelled ) { int ret = pthread_kill(tid, 0); if( ret ) break; - usleep(200000); + usleep(10000); } tid = ((pthread_t)-1); }