diff options
Diffstat (limited to 'src/libthread/thread.c')
| -rw-r--r-- | src/libthread/thread.c | 19 |
1 files changed, 14 insertions, 5 deletions
diff --git a/src/libthread/thread.c b/src/libthread/thread.c index 8f838b62..1837e7d9 100644 --- a/src/libthread/thread.c +++ b/src/libthread/thread.c @@ -138,15 +138,23 @@ _threadready(_Thread *t) p = t->proc; lock(&p->lock); addthread(&p->runqueue, t); - _procwakeup(&p->runrend); +//print("%d wake for job %d->%d\n", time(0), getpid(), p->osprocid); + if(p != proc()) + _procwakeup(&p->runrend); unlock(&p->lock); } -void +int threadyield(void) { - _threadready(proc()->thread); + int n; + Proc *p; + + p = proc(); + n = p->nswitch; + _threadready(p->thread); _threadswitch(); + return p->nswitch - n; } void @@ -184,13 +192,14 @@ scheduler(Proc *p) if(p->nthread == 0) goto Out; p->runrend.l = &p->lock; -print("sleep for jobs %d\n", getpid()); +//print("%d sleep for jobs %d\n", time(0), getpid()); _procsleep(&p->runrend); -print("wake from jobs %d\n", getpid()); +//print("%d wake from jobs %d\n", time(0), getpid()); } delthread(&p->runqueue, t); unlock(&p->lock); p->thread = t; + p->nswitch++; // print("run %s %d\n", t->name, t->id); contextswitch(&p->schedcontext, &t->context); p->thread = nil; |