Goroutine ведет себя по-разному в Windows и Linux

Question

Я не знаком с GO. У меня есть следующий код устаревшего кода.

var db *sql.DB 

func init() { 
    go feedChan() 

    connString := os.Getenv("DB_CONN") 
    var err error 

    db, err = sql.Open("postgres", connString) 
    if err != nil { 
     log.Fatalf("Failed to connect to database at %q: %q\n", connString, err) 
    } 

    // confirm connection 
    if err = db.Ping(); err != nil { 
     log.Fatalf("Unable to ping database at %q: %q\n", connString, err) 
    } 
} 


func feedChan() { 
    selectQuery, err := db.Prepare(` 
     SELECT id, proxy 
     FROM proxy 
     WHERE fail_count < 2 
     ORDER BY date_added DESC, last_used ASC, fail_count ASC 
     LIMIT 5 
    `) 
    .... 

Следующий код работает над linux. Но это не будет работать на окна с ошибкой ноль на

selectQuery, err := db.Prepare(` 

Какой смысл для меня, так как БД инициализируется после запуска feedChan goroutine. Что для меня не имеет смысла, так это то, почему он работает на Linux.

Итак, вопрос в том, почему этот код работает в Linux без ошибок?

Answer 1

Это, вероятно, race condition. Импорт "time", добавьте эту строку после go feedChan(), и посмотреть, если он все еще работает на Linux:

time.Sleep(3 * time.Second) 

Для того, чтобы избежать этой ситуации, вы можете либо инициализировать dbперед тем вы икру рутину (который использует db) или использовать какие-то barrier:

func init() { 
    barrier := make(chan int) 
    go feedChan(barrier) 

    connString := os.Getenv("DB_CONN") 
    var err error 
    db, err = sql.Open("postgres", connString) 

    if err != nil { 
     log.Fatalf("Failed to connect to database at %q: %q\n", connString, err) 
     // Retry. 
    } else { 
     barrier <- 1 // Opens barrier. 
    } 
    // ... 
} 


func feedChan(barrier chan int) { 
    <-barrier // Blocks until db is ready. 
    selectQuery, err := db.Prepare(` 
     SELECT id, proxy 
     FROM proxy 
     WHERE fail_count < 2 
     ORDER BY date_added DESC, last_used ASC, fail_count ASC 
     LIMIT 5 
    `) 
    // ... 
} 

Answer 2

После прочтения первых строк ваших функций я просто не могу вам сказать, что ваш старый код имеет огромной ошибки и ч n легко фиксируется, просто перемещая эту строку go feedChan() до конца функции init().

Также обратите внимание, что основной причиной является не состояние гонки, просто вопрос ожидания правильной инициализации db переменная.