Основная нить не доходит до goroutine

Question

• Редактировать * - раскорить две строки времени выполнения и изменить Tick() на Sleep(), и он работает как ожидается, печатает один номер каждую секунду. Оставляя код, так это ответ и комментарии имеют смысл.

идти версия go1.4.2 Darwin/amd64

Когда я запускаю следующее, я никогда не видел ничего напечатал от go Counter().

package main 

import (
    "fmt" 
    "time" 
    //"runtime" 
) 

var count int64 = 0 

func main() { 
    //runtime.GOMAXPROCS(2) 
    fmt.Println("main") 
    go Counter() 
    fmt.Println("after Counter()") 
    for { 
    count++ 
    } 
} 

func Counter() { 
    fmt.Println("In Counter()") 
    for { 
    fmt.Println(count) 
    time.Tick(time.Second) 
    } 
} 

> go run a.go 
main 
after Counter() 

Если я раскомментировать выполнения вещи, я буду получать некоторые странные результаты, как следующие все печатные сразу (а не второй друг от друга):

> go run a.go 
main 
after Counter() 
In Counter() 
10062 
36380 
37351 
38036 
38643 
39285 
39859 
40395 
40904 
43114 

Что я ожидаю, что go Counter() будет печатать все count происходит каждую секунду, пока он непрерывно увеличивается по основному потоку. Я не столько ищу другого кода, чтобы сделать то же самое. Мой вопрос больше о том, что происходит, и где я ошибаюсь в своих ожиданиях? Вторые результаты, в частности, не имеют никакого смысла, печатаются все сразу. Насколько мне известно, они никогда не должны печататься ближе, чем я могу сказать, не так ли?

Answer 1

В вашей жесткой петле for ничего не происходит, что позволяет запустить планировщик Go. Расписание рассматривает другие goroutines всякий раз, когда вы блокируете или на некоторых (которые? Все?) Вызовы функций.

Поскольку вы не сделаете ни одно из самых простых решений, это добавить звонок в runtime.Gosched. Например .:

for { 
    count++ 
    if count % someNum == 0 { 
     runtime.Gosched() 
    } 
} 

отметить также, что запись и чтение ту же переменную из разных goroutines без блокировки или синхронизации гонки данных и there are no benign data races, ваша программа могла бы сделать что-нибудь при чтении значения, как это пишется. (И синхронизация также позволит запустить планировщик Go.)

Для простого счетчика вы можете избежать блокировок с помощью atomic.AddInt64(&var, 1) и atomic.LoadInt64(&var).

Обратите внимание, что time.Tick ничего не задерживает, возможно, вам потребовалось time.Sleep или for range time.Tick(…).