1
0
mirror of https://github.com/golang/go synced 2024-11-26 09:08:07 -07:00

runtime: ensure forward progress of runtime.Gosched() for locked goroutines

The removed code leads to the situation when M executes the same locked G again and again.
Fixes #4820.

R=golang-dev, rsc
CC=golang-dev
https://golang.org/cl/7310096
This commit is contained in:
Dmitriy Vyukov 2013-02-15 22:22:13 +04:00
parent d3d89ae7d2
commit f87b7f67b2
2 changed files with 30 additions and 8 deletions

View File

@ -389,14 +389,6 @@ canaddmcpu(void)
static void static void
gput(G *gp) gput(G *gp)
{ {
M *mp;
// If g is wired, hand it off directly.
if((mp = gp->lockedm) != nil && canaddmcpu()) {
mnextg(mp, gp);
return;
}
// If g is the idle goroutine for an m, hand it off. // If g is the idle goroutine for an m, hand it off.
if(gp->idlem != nil) { if(gp->idlem != nil) {
if(gp->idlem->idleg != nil) { if(gp->idlem->idleg != nil) {

View File

@ -46,6 +46,36 @@ func TestStopTheWorldDeadlock(t *testing.T) {
runtime.GOMAXPROCS(maxprocs) runtime.GOMAXPROCS(maxprocs)
} }
func TestYieldProgress(t *testing.T) {
testYieldProgress(t, false)
}
func TestYieldLockedProgress(t *testing.T) {
testYieldProgress(t, true)
}
func testYieldProgress(t *testing.T, locked bool) {
c := make(chan bool)
cack := make(chan bool)
go func() {
if locked {
runtime.LockOSThread()
}
for {
select {
case <-c:
cack <- true
break
default:
runtime.Gosched()
}
}
}()
time.Sleep(10 * time.Millisecond)
c <- true
<-cack
}
func TestYieldLocked(t *testing.T) { func TestYieldLocked(t *testing.T) {
const N = 10 const N = 10
c := make(chan bool) c := make(chan bool)