Почему возвращает значение третей рутины?

Question

[v- smerti]

Я делаю простенький кластер (в научных целях)

У меня есть домен
example.com на нём код который по идее должен вернуть мне имя сервера который ответил быстрее всех. Но почему то всегда отвечал server3 первым. Не долго думая я привёл свой код где просто используеться fmt.print

package main

import "fmt"

func getDataFromServer(res chan string, serverName string) {
	fmt.Println(serverName)
	res <- serverName
}

func main() {
	res := make(chan string, 3)
	go getDataFromServer(res, "Server1")
	go getDataFromServer(res, "Server2")
	go getDataFromServer(res, "Server3")

	data := <- res
	fmt.Println(data)
}

По идее в этом коде 1 горутина должна завершаться первой и в терминал должно быть напечатано server1 но почему то постоянно печатает server3

А вот код которым я проверяю сервера

package main

import (
	"fmt"
	"log"
	"net/url"
)

func getDataFromServer(res chan string, serverName string) {
	ur := "http://" + serverName + "example.com"
	_, err := url.Parse(ur)
	if err != nil {
		log.Fatal(err)
	} else {
		res <- ur
	}
}

func main() {
	res := make(chan string, 3)
	go getDataFromServer(res, "Server1")
	go getDataFromServer(res, "Server2")
	go getDataFromServer(res, "Server3")
	go getDataFromServer(res, "Server4")
	go getDataFromServer(res, "Server5")

	data := <-res
	//по идее здесь должен быть url который ответил быстрее всех. Но почему то выводит адрес Server5 всегда
	fmt.Println(data)
}

Зарание спасибо

Answer 1

[Александр Павлюк]

Go не гарантирует порядок выполнения горутин. Так что server1 не обязательно будет первым.

Comments

[v- smerti]

А как тогда это обойти? Мне надо одновременно отправить запрос на n-ное количество серверов и перенаправить пользователя на тот который ответил первым не дожидаясь ответа от остальных

[Александр Павлюк]

Владимир Грабко: когда тут будут реальные обращения к серверам, возвращать оно будет действительно самый быстрый из них. Главное не забывайте, что остальные горутины у вас будут висеть, пытаясь писать в канал. Так что вам нужно или дочитать остальные ответы в отдельной горутине или изучить понятие context в go для отмены запросов.

[v- smerti]

Александр Павлюк: я шлю на vk.com gmail.com mail.ru всегда говорит что последняя горутина самая быстрая

[Александр Павлюк]

Владимир Грабко: приведите код, в котором вы реально шлете запросы

[v- smerti]

Александр Павлюк:

package main

import (
	"fmt"
	"log"
	"net/url"
)

func getDataFromServer(res chan string, serverName string) {
	_, err := url.Parse(serverName)
	if err != nil {
		log.Fatal(err)
	} else {
		res <- serverName
	}
}

func main() {
	res := make(chan string, 3)
	go getDataFromServer(res, "http://vk.com/")
	go getDataFromServer(res, "http://gmail.com")

	data := <-res
	fmt.Println(data)
}

[Oleg Shevelev]

Странно тут ожидать полноценного генератора случайных вариантов. Оно тут вовсе не нужно. По части распределения нагрузки (а ведь обычно для неё делается такой финт с самым быстрым ответом) лучше сделать так:
Отправлять задачи на сервера по кругу, считать время ответа, если какой-то сервер выбивается по времени ответа - убирать его из списка или ставить в самый конец относительно текущей позиции... или пропускать его при следующем запросе или ещё что-то...

[Александр Павлюк]

Владимир Грабко: проблема в том, что здесь у вас не отправляется запрос никуда. Просто парсится урл и всё.

[v- smerti]

Александр Павлюк: спасибо!

Answer 2

[Oleg Shevelev]

Вот два примера для проверки что всё на самом деле работает верно (если мы правильно понимаем в чём вопрос).

package main

import "fmt"
import "time"

func getDataFromServer(res chan string, serverName string, delay int64) {
	fmt.Println(serverName)
	time.Sleep(time.Duration(delay)*time.Second)
	res <- "test_"+serverName
}

func main() {
  res := make(chan string, 3)
  go getDataFromServer(res, "Server1", 10)
  go getDataFromServer(res, "Server2", 11)
  go getDataFromServer(res, "Server3", 12)

  data := <- res
  fmt.Println(data)
}
Server3
Server1
Server2
test_Server1

package main

import "fmt"
import "time"

func getDataFromServer(res chan string, serverName string, delay int64) {
	fmt.Println(serverName)
	time.Sleep(time.Duration(delay)*time.Second)
	res <- "test_"+serverName
}

func main() {
  res := make(chan string, 3)
  go getDataFromServer(res, "Server1", 15)
  go getDataFromServer(res, "Server2", 11)
  go getDataFromServer(res, "Server3", 12)

  data := <- res
  fmt.Println(data)
}
Server3
Server1
Server2
test_Server2

Golang сам решает когда контекст переключать для большей производительности и меньших накладных расходов.