Телеграмм чат группы gogolang страница 25531

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

источник

18:55пожаловаться #4

Vladislav Yarmak in Go-go!

это почему?

источник

18:55пожаловаться #5

Andrei Grazhdankov in Go-go!

Queue priority может?

источник

18:55пожаловаться #6

Andrei Grazhdankov in Go-go!

Heap

источник

18:55пожаловаться #7

Nekto in Go-go!

таак, если есть идеи почему не так. то расскажите plz, может я что-то упускаю.

источник

18:55пожаловаться #8

Andrei Grazhdankov in Go-go!

Но там будет mutex нужен

источник

18:56пожаловаться #9

Vladislav Yarmak in Go-go!

ну вот у вас там выше код, который работает под семафором. суть его в том, что не больше N слотов разбирают очередь

источник

18:56пожаловаться #10

pragus in Go-go!

Нет. Чисто работа с индексами.

источник

18:57пожаловаться #11

Vladislav Yarmak in Go-go!

если то же самое сделать просто фиксированным числом воркеров, выгребая конкурентно из очереди, получится в сущности то же самое, но только очерёдность будет сохранена

источник

18:57пожаловаться #12

pragus in Go-go!

http://www.mathcs.emory.edu/~cheung/Courses/171/Syllabus/8-List/array-queue2.html

источник

18:58пожаловаться #13

Nekto in Go-go!

а как реализуется очередь - это что такое в вашей реализации?

В текущей реализации, если очередь 100к - то это 100к вызовов Acquire , а внутри Acquire есть код

select {
case <-ctx.Done():
case <-ready:
}

те если контекст истечет, то сразу семафор освободится с err

источник

18:59пожаловаться #14

Vladislav Yarmak in Go-go!

щас очередь где хранится?

источник

19:00пожаловаться #15

Vladislav Yarmak in Go-go!

просто в том, что запущенные горутины толпятся и ждут исполнения?

источник

19:00пожаловаться #16

Nekto in Go-go!

да, ограничены размером semaphore.Weighted()