goroutine

1зной

1ответ

Golang os.stdin как читатель в Goroutines

Можно ли использовать os.stdin как Reader в Goroutine? В основном, я хотел бы сделать это, чтобы позволить пользователю вводить сообщение без блокировки основного потока. Пример: go func() { for

go buffer stdin goroutine reader 2015-11-17

---

1зной

1ответ

sync.Cond Test Broadcast - зачем регистрироваться в цикле?

Я пытался использовать sync.Cond - Wait and Broadcast. Я не мог понять некоторые его части: Комментарий к Wait называет говорит: 41 // Because c.L is not locked when Wait first resumes, the caller

go synchronization goroutine 2015-11-21

---

2зной

1ответ

Программа GoLang, выполняющаяся на одной нити даже с GOMAXPROCS (4)

В следующей программе GoLang я пытаюсь реализовать stable marriage problem для N мужчин и женщин N, используя 2 * N goroutines (по 1 для каждого мужчины и женщины). Программа внимательно следит за опр

multithreading go goroutine 2015-11-26

---

0зной

1ответ

Перейти к файлу IO не удается при записи во время итерации по каналу

У меня возникла проблема с записью строк в файл csv, итерации по каналу. Я новичок в Go, но синтаксис для файла IO выглядит синхронно мне. Учитывая, что я ожидаю, что операция записи, успешно возвраще

go io channel goroutine 2015-12-03

---

2зной

2ответ

Предотвращение прерывания Ctrl + C от exec.Command в Golang

Я заметил, что процессы, начатые с exec.Command, прерываются, даже когда вызов прерывания перехвачен через signal.Notify. Я сделал следующий пример, чтобы показать проблему: package main import (

multithreading go subprocess goroutine sigint 2015-10-16

---

1зной

3ответ

golang идиоматического способа остановить для

Я новичок Пойти так что я заранее извиняюсь, если ответ на мой вопрос очевиден :) Я планирую продюсер, который читает файл и отправить каждую строку канал, например: scanner := bufio.NewScanner(file)

go goroutine 2015-10-28

---

6зной

1ответ

Простой метод ограничения параллелизма в Go

У меня есть CSV-файл с ~ 10k URL-адресами, которые мне нужны для HTTP-получения. Каков самый простой способ ограничить параллелизм подпрограмм Go не более 16 раз за раз? func getUrl(url string) {

go goroutine 2015-11-01

---

3зной

2ответ

Почему этот код генерирует ошибку?

Ниже приведен код ошибки, почему? func main() { messages := make(chan string) messages <- "test" //line 16 fmt.Println(<-messages) } Создает нижеследующую ошибку. fatal error: al

go channel goroutine 2015-11-08

---