Очередная непонятная ситуация с Go?

Question

[Pavel Shvedov]

Всем привет, сразу к делу. Код:

for _ = range time.Tick(3 * time.Second) {
		fmt.Println("Making query")
		rows, err := db.Query("SELECT id, addr, method FROM tasks")
		defer rows.Close()
		if err != nil {
			fmt.Printf("Database error: %s\n", err.Error())
			os.Exit(1)
		} else {
			fmt.Println("Filling queue")
			queue := make(chan *Task)
			for rows.Next() {
				fmt.Println("Get next row")
				var id int32
				var addr string
				var method string
				if err := rows.Scan(&id, &addr, &method); err != nil {
					fmt.Printf("Row error: %s\n", err.Error())
				} else {
					fmt.Printf("Add task for: %s\n", addr)
					queue <- &Task{id, addr, method}
					fmt.Println("Task added")
				}
			}
			fmt.Println("Queue filled")
			close(queue)
			process(queue)
		}
	}

Читаю строки из БД, при первой итерации rows.Next() данные нормально извлекаются, но когда запихиваю полученный результат в channel, все просто встает на этом шаге.
queue <- &Task{id, addr, method}
Что я делаю не так?

Answer 1

[SilentFl]

Как и в предыдущем вашем вопросе - блокировка из-за небуферизованного канала.

Answer 2

[Виталий Яковенко]

У вас опять небуферизированый канал. Чё-то вы ошибки повторяете свои =)

Comments

[Виталий Яковенко]

Сделайте
go process(queue)
перед
for rows.Next()
и будет вам счастье.

[Pavel Shvedov]

Стоп, я же в прошлом своем вопросе запись в канал делал путем
queue <- &Task{0, "localhost", "HEAD"}
queue <- &Task{1, "google.ru", "HEAD"}
queue <- &Task{2, "yandex.ru", "HEAD"}
...
и между ними задержек не было

[SilentFl]

все правильно, задержек не было потому что было queue := make(chan *Task, 50). Сейчас же у вас снова канал "на одну персону" queue := make(chan *Task)

[Pavel Shvedov]

Ясно, блин эта идеология пока никак не хочет уложиться в мозгу. Спасибо

[Виталий Яковенко]

Pavel Shvedov: в случае работы с БД я вам настоятельно рекомендую сделать так, как я выше написал. Подумайте, что будет верни запрос больше строк, чем у вас размер буффера.