Как я могу предотвратить гонку данных при добавлении обработчиков в программу? - PullRequest
Новая
       7

Как я могу предотвратить гонку данных при добавлении обработчиков в программу?

0 голосов
/ 30 апреля 2018

В моем приложении HTTP, написанном на golang, у меня есть несколько маршрутов, которые полагаются на сторонние сервисы (и сторонний код), чтобы выполнить некоторую работу, прежде чем я действительно смогу зарегистрировать маршрут. Это может произойти сбой или необходимо повторить попытку, но я все же хочу, чтобы приложение отвечало на другие запросы, пока этот процесс потенциально выполняется.

Это означает, что я регистрирую обработчики на http.DefaultServeMux в процедурах, которые я порождаю из моего main функции. Это работает, как и ожидалось, но мои тесты теперь будут жаловаться на гонки данных.

Минимальный случай для воспроизведения выглядит так: 

package main

import (
    "log"
    "net/http"
)

func main() {
    go func() {
        http.HandleFunc("/hello", func(w http.ResponseWriter, r *http.Request) {
            w.Write([]byte("hello"))
        })
    }()
    srv := http.Server{
        Addr: ":3000",
    }
    log.Fatal(srv.ListenAndServe())
}

С тестом вроде: 

package main

import (
    "io/ioutil"
    "net/http"
    "os"
    "testing"
    "time"
)

func TestMain(m *testing.M) {
    go main()
    time.Sleep(time.Second)
    os.Exit(m.Run())
}

func TestHello(t *testing.T) {
    t.Run("default", func(t *testing.T) {
        res, err := http.DefaultClient.Get("http://0.0.0.0:3000/hello")
        if err != nil {
            t.Fatalf("Calling /hello returned %v", err)
        }
        if res.StatusCode != http.StatusOK {
            b, _ := ioutil.ReadAll(res.Body)
            defer res.Body.Close()
            t.Errorf("Expected /hello to return 200 response, got %v with body %v", res.StatusCode, string(b))
        }
    })
}

покажет мне следующий вывод: 

==================
WARNING: DATA RACE
Read at 0x000000a337d8 by goroutine 14:
  net/http.(*ServeMux).shouldRedirect()
      /usr/local/go/src/net/http/server.go:2239 +0x162
  net/http.(*ServeMux).redirectToPathSlash()
      /usr/local/go/src/net/http/server.go:2224 +0x64
  net/http.(*ServeMux).Handler()
      /usr/local/go/src/net/http/server.go:2293 +0x184
  net/http.(*ServeMux).ServeHTTP()
      /usr/local/go/src/net/http/server.go:2336 +0x6d
  net/http.serverHandler.ServeHTTP()
      /usr/local/go/src/net/http/server.go:2694 +0xb9
  net/http.(*conn).serve()
      /usr/local/go/src/net/http/server.go:1830 +0x7dc

Previous write at 0x000000a337d8 by goroutine 8:
  net/http.(*ServeMux).Handle()
      /usr/local/go/src/net/http/server.go:2357 +0x216
  net/http.(*ServeMux).HandleFunc()
      /usr/local/go/src/net/http/server.go:2368 +0x62
  net/http.HandleFunc()
      /usr/local/go/src/net/http/server.go:2380 +0x68
  github.com/m90/test.main.func1()
      /home/frederik/projects/go/src/github.com/m90/test/main.go:10 +0x4f

Goroutine 14 (running) created at:
  net/http.(*Server).Serve()
      /usr/local/go/src/net/http/server.go:2795 +0x364
  net/http.(*Server).ListenAndServe()
      /usr/local/go/src/net/http/server.go:2711 +0xc4
  github.com/m90/test.main()
      /home/frederik/projects/go/src/github.com/m90/test/main.go:17 +0xb6

Goroutine 8 (finished) created at:
  github.com/m90/test.main()
      /home/frederik/projects/go/src/github.com/m90/test/main.go:9 +0x46
==================

Насколько я понимаю, чтение кода пакета http net/http.(*ServeMux).Handler() в трассировке стека не блокирует мьютекс, который защищает карту обработчика, так как он ожидает, что это будет сделано net/http.(*ServeMux).handler(), который в моем Сценарий не вызывается.

Я делаю что-то, что не должно быть сделано? Это проблема со стандартной библиотекой? Я делаю что-то не так в том, как я прикрепляю обработчики в программе?

1 Ответ

0 голосов
/ 30 апреля 2018

Это, похоже, проблема в самом пакете http, которая решается с помощью этого запроса на извлечение .

По состоянию на апрель 2018 года патч не включен в go1.10.1, но он должен поставляться с go1.11

...