ref: d8d47f14b5ed8f6d3f892761ed86c6ce2075c337
dir: /sys/src/libthread/exit.c/
#include <u.h> #include <libc.h> #include <thread.h> #include "threadimpl.h" #include <tos.h> char *_threadexitsallstatus; Channel *_threadwaitchan; void threadexits(char *exitstr) { Proc *p; Thread *t; p = _threadgetproc(); t = p->thread; t->moribund = 1; if(exitstr==nil) exitstr=""; utfecpy(p->exitstr, p->exitstr+ERRMAX, exitstr); _sched(); } void threadexitsall(char *exitstr) { Proc *p; int pid[64]; int i, npid, mypid; if(exitstr == nil) exitstr = ""; _threadexitsallstatus = exitstr; _threaddebug(DBGSCHED, "_threadexitsallstatus set to %p", _threadexitsallstatus); mypid = _tos->pid; //getpid(); /* * signal others. * copying all the pids first avoids other threads * teardown procedures getting in the way. * * avoid mallocs since malloc can post a note which can * call threadexitsall... */ for(;;){ lock(&_threadpq.lock); npid = 0; for(p = _threadpq.head; p && npid < nelem(pid); p=p->next){ if(p->threadint == 0 && p->pid != mypid){ pid[npid++] = p->pid; p->threadint = 1; } } unlock(&_threadpq.lock); if(npid == 0) break; for(i=0; i<npid; i++) postnote(PNPROC, pid[i], "threadint"); } /* leave */ exits(exitstr); } Channel* threadwaitchan(void) { if(_threadwaitchan==nil) _threadwaitchan = chancreate(sizeof(Waitmsg*), 16); return _threadwaitchan; }