Почему эта программа заканчивается в моей системе, но не на детской площадке?

Question

Рассмотрим эту программу:

package main 

import "fmt" 
import "time" 
import "runtime" 

func main() { 

    x := 0 

    go func() { 
     time.Sleep(500 * time.Millisecond) 
     x = 1 
    }() 

    for x == 0 { 
     runtime.Gosched() 
    } 

    fmt.Println("it works!") 
} 

Почему это прекратить на месте, но не на Playground? Оканчивает ли моя программа зависимость от неопределенного поведения?

Answer 1

Этот код не предоставляет много гарантий. Он почти полностью опирается на детали реализации вокруг неопределенного поведения.

В большинстве многопоточных систем нет гарантии, что изменение одной нити без барьера будет видно в другом. У вас есть goroutine, который может работать на другом процессоре, вообще говоря, значение переменной, которую никто никогда не сможет прочитать.

for x == 0 { может быть легко переписан на for {, так как никогда не было никаких гарантий, что изменения этой переменной могут быть видны.

Идентификатор гонки также, вероятно, сообщит об этой проблеме. Вы действительно не должны ожидать, что это сработает. Если вы хотите sync.WaitGroup, вы должны просто использовать его так, как он правильно координирует потоки.

Answer 2

На игровой площадке Go используется специальная реализация time.Sleep, предназначенная для предотвращения монополизации отдельных программ на ресурсы задней части сайта.

Как описано в this article about the how the playground is implemented, goroutines, вызывающие time.Sleep(), усыпляются. Передняя часть детской площадки ждет, пока все остальные горуты не будут заблокированы (что в противном случае было бы тупиком), а затем разбудит горутин с самым коротким временем.

В вашей программе у вас есть два гортани: главный, и один, который вызывает time.Sleep. Поскольку главный горутин никогда не блокируется, вызов time.Sleep никогда не вернется. Программа продолжается до тех пор, пока она не превысит выделенное ей время ЦП и затем прекратится.

Answer 3

Модель памяти Go не гарантирует, что значение, записанное в x в goroutine, будет наблюдаться основной программой. Аналогично ошибочная программа приведена в качестве примера в разделе, посвященном go routine destruction. Модель памяти Go также специально вызывает ожидание ожидания без синхронизации в качестве неправильной идиомы в this section.

Вам необходимо выполнить какую-то синхронизацию в goroutine, чтобы гарантировать, что x = 1 происходит до одной из итераций цикла for в main.

Вот версия программы, которая гарантированно будет работать по назначению.

http://play.golang.org/p/s3t5_-Q73W

package main 

import (
    "fmt" 
    "time" 
) 

func main() { 
    c := make(chan bool) 
    x := 0 

    go func() { 
     time.Sleep(500 * time.Millisecond) 
     x = 1 
     close(c) // 1 
    }() 

    for x == 0 { 
     <-c // 2 
    } 

    fmt.Println("it works!") 
} 

Гарантии Go Модель памяти, что линия, помеченные // 1 происходит перед линией, обозначенной // 2. В результате, для цикла гарантированно завершить до его вторая итерация.