Ответы, понравившиеся пользователю Даниил

Как правильно взаимодействовать с каналами?

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

То, что в канал данные пишутся медленнее, чем читаются, не должно вызывать никаких проблем при правильном подходе. У вас просто очень странно написан воркер, он на каждое событие запускает горутину и почему-то останавливается, если буфер канала пустой. Воркера надо по-хорошему останавливать, когда канал закрыт, а не пуст.

Лучше сделать так

package main

import (
	"bufio"
	"fmt"
	"os"
	"sync"
)

func main() {
	urls := make(chan string)
	go fillChannel(urls)

	// создаем группу для ожидания, того, что все воркеры завершены
	wg := &sync.WaitGroup{}

	for i := 0; i < 5; i++ {
		// при запуске каждого воркера, увеличиваем счетчик в группе на 1
		wg.Add(1)
		go requestWorker(urls, wg)
	}

	// ждем, пока счетчик в группе не будет равен 0
	wg.Wait()
}

func requestWorker(channel <-chan string, wg *sync.WaitGroup) {
	// По завершении воркера счетчик в группе будет уменьшен на 1
	defer wg.Done()
	// Заодно пишем сообщение о завершении воркера
	defer println("Worker stopped")

	// Постоянно читаем из канала новые сообщения
	// цикл автоматически завершится, когда канал закроется и буфер будет пуст
	for url := range channel {
		println(url)
	}
}

func fillChannel(channel chan<- string) {
	file, err := os.Open("data.txt")
	defer file.Close()

	if err != nil {
		fmt.Println(err)
		return
	}

	fileScanner := bufio.NewScanner(file)
	fileScanner.Split(bufio.ScanLines)

	for fileScanner.Scan() {
		channel <- fileScanner.Text()
	}

	// закрываем канал, когда данные кончились
	// в го принято, чтобы канал закрывал только тот, кто в него пишет
	close(channel)
}

Этот паттерн называется worker pool. Мы пишем в канал все нужные данные и закрываем канал, когда данные кончились. Благодаря тому, что воркеры читают из канала через range, цикл просто выходит, когда канал закрыт и воркеры завершаются.
WaitGroup используется для того, чтобы подождать, пока воркеры доработают последние данные.

Ответ написан более двух лет назад

Комментировать

Как использовать форк пакета в Го?

uvelichitel @uvelichitel Куратор тега Go

habrahabr.ru/users/uvelichitel

Всего две команды:
подмена

go mod edit -replace github.com/orig/pkg v1.0.0=github.com/my/fork/pkg v1.0.0

или на локальный репо

go mod edit -replace github.com/orig/pkg v1.0.0=/local/path/onyourmachine

вернуть обратно когда ваш PR закоммитят

go mod edit -dropreplace  github.com/orig/pkg v1.0.0

А можно подправить go.mod вручную. В нём должно появиться

replace github.com/orig/pkg v1.0.0  => github.com/my/fork/pkg v1.0.0

В исходниках при этом менять импорты не нужно.

Ответ написан более двух лет назад

1 комментарий

Бывают ли сервисы - переадресователи мейлов?

Styxian @Styxian

Добрый день.
Есть несколько проверенных сервисов для скрытия своего основного адреса:
anonaddy.com
simplelogin.io
Оба сервиса имеют возможность бесплатного использования. На платной основе пристувует возможность привязать свой домен. У проектов открытый исходный код и их можно поднять на своём сервере.

Войдите на сайт