Неблокирующая функция

@_FoCuS · Регистрация: 02.11.2017

Студворк — интернет-сервис помощи студентам

у меня задача: написать функцию func test(f func(int) int, in1 <-chan int, in2 <- chan int, out chan<- int, n int) в package main.
она
n раз сделать следующее

1. прочитать по одному числу из каждого из двух каналов in1 и in2, назовем их x1 и x2.
2. вычислить f(x1) + f(x2)
3. записать полученное значение в out
Функция test должна быть неблокирующей, сразу возвращая управление.
Функция f может работать долгое время, ожидая чего-либо или производя вычисления.

Формат ввода
Количество итераций передается через аргумент n.
Целые числа подаются через аргументы-каналы in1 и in2.
Функция для обработки чисел перед сложением передается через аргумент f.

Код на go - вопрос как сделать функцию неблокирующей? в чем у меня ошибка?
еще при сборке ругается cannot be extracted via extract ()

Go
1
2
3
4
5
6
7
8
9
10
11
12
package main
 
// this is a comment
func test(f func(int) int, in1 <-chan int, in2 <- chan int, out chan<- int, n int) {
 
    for i := 0; i < n; i++ {
        var x1 int = <- in1
        var x2 int = <- in2
        var res int = f(x1) + f(x2)
        out <- res
    }
}

@mplain · 27.05.2020, 00:22

Joker5555
Или можно вместо структуры завести дополнительные каналы с буфером n, обсуждалось уже такое

Мне только непонятно, где здесь может быть гонка по считыванию? считыванию чего, какой переменной?

@Joker5555 · 27.05.2020, 00:28

Сообщение от mplain

Или можно вместо структуры завести дополнительные каналы с буфером n, обсуждалось уже такое

насчёт каналов я не особо уловил мысль, мы туда поочерёдно класть будем или результат?

Добавлено через 3 минуты

Сообщение от mplain

Мне только непонятно, где здесь может быть гонка по считыванию? считыванию чего, какой переменной?

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

@mplain · 27.05.2020, 00:31

Я подумал, что ошибки могут возникать, потому что каналы in1, in2, out не имеют буфера и забиваются, поэтому сделал вот так:

Go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
package main
 
func Merge2Channels(f func(int) int, in1 <-chan int, in2 <-chan int, out chan<- int, n int) {
    loop := func(f func()) { for i := 0; i < n; i++ { f() } }
    in1buffer := make(chan int, n)
    in2buffer := make(chan int, n)
    out1buffer := make(chan int, n)
    out2buffer := make(chan int, n)
    go loop(func() { out <- <-out1buffer + <-out2buffer })
    go loop(func() { out1buffer <- f(<-in1buffer) })
    go loop(func() { out2buffer <- f(<-in2buffer) })
    go loop(func() { in1buffer <- <-in1 })
    go loop(func() { in2buffer <- <-in2 })
}

то есть создаём четыре новых канала с буфером в n элементов каждый, и пять горутин:
- две получают значения из in1 и in2 по мере поступления и направляют в каналы с буфером
- еще две параллельно вычисляют f(x1) и f(x2), на случай если функция высчитывается долго (но при условии что она stateless)
- пятая горутина получает итоговое значение и направляет его в out

всё это сделано на случай если хитрость задачи в том что каналы забиваются, пока f() высчитывается
но это всё ерунда, из входящих каналов все числа поступают без задержек

если попытаться передать в out неверное значение (например произвольное), получаешь вполне конкретную ошибку panic: вы передали значение 12345, а нужно 67890

@Joker5555 · 27.05.2020, 00:35

Сообщение от mplain

всё это сделано на случай если хитрость задачи в том что каналы забиваются, пока f() высчитывается
но это всё ерунда, из входящих каналов все числа поступают без задержек

вот наверное в том и суть, что мы вычисляем параллельно f() и может быть происходит так, что в out записываются разные суммы пар, т.е надо как-то перехватывать f(x1) и f(x2) на выходе.

@mplain · 27.05.2020, 00:38

так нет никакой разницы по факту, считаешь ты f() параллельно или последовательно - результат одинаковый

@Joker5555 · 27.05.2020, 00:44

Сообщение от mplain

так нет никакой разницы по факту, считаешь ты f() параллельно или последовательно - результат одинаковый

panic: Got 142820 from output channel, should be 83602 [recovered]
panic: Got 142820 from output channel, should be 83602
да вот нет, это результат последовательного выполнения

func Merge2Channels(f func(int) int, in1 <-chan int, in2 <-chan int, out chan<- int, n int) {
x := 0
y := 0
for i := 0; i < n; i++ {
go func() {
out <- f(x) + f(y)
}()
x = <-in1
y = <-in2
}
}

По сути это и есть WA, с конкретным тестом. Просто RE срабатывает из-за тестирующей системы

@mplain · 27.05.2020, 00:48

У меня вот последовательное вычисление, и оно паник не выдаёт, только wrong answer

Go
1
2
3
4
5
6
7
8
9
package main
 
func Merge2Channels(f func(int) int, in1 <-chan int, in2 <-chan int, out chan<- int, n int) {
    go func() {
        for i := 0; i < n; i++ {
            out <- f(<-in1) + f(<-in2)
        }
    }()
}

Кстати, на Я.контесте новое объявление жюри. В нём они сказали, что описание задач у них нормальное, просто решение у нас неправильно. Еще сказали, что спалили этот форум, мы читеры, а решения, здесь опублиокванные, не будут засчитываться

@Joker5555 · 27.05.2020, 00:49

Сообщение от mplain

Кстати, на Я.контесте новое объявление жюри. В нём они сказали, что описание задач у них нормальное, просто решение у нас неправильно. Еще сказали, что спалили этот форум, мы читеры, а решения, здесь опублиокванные, не будут засчитываться

точнее будут ревьюрится по видеосвязи

@mplain · 27.05.2020, 00:49

Code
1
2
for i := 0; i < n; i++ {
go func() {

так ты здесь создаёшь n горутин, вот они-то у тебя и вступают в гонку
я создаю одну горутину, которая всё делает последовательно

@lokilo · 27.05.2020, 05:37

korvin_, WA - неверный ответ, но моему мнению, наебашили они охрененные тесты, которые хрен пойми, как работают

@Neko-neko · 27.05.2020, 11:23

Сообщение от mplain

Кстати, на Я.контесте новое объявление жюри. В нём они сказали, что описание задач у них нормальное, просто решение у нас неправильно. Еще сказали, что спалили этот форум, мы читеры, а решения, здесь опублиокванные, не будут засчитываться

Ага, ещё сказали, что погорячились с ограничениями для задачи F, добавили полсекунды времени.
(Интересно, что на это скажут те, кто и в секунду укладывался...)

@ColdSkull · 27.05.2020, 12:02

Neko-neko, Действительно, лучше бы для Е тесты исправили. Непонятно что ему не нравится. Судя по отзывам тест на это задание в принципе не проходит, даже если оно корректно. Фиксить не будут, если боятся потерять результаты, непонятно почему бы просто не добавить ещё одно исправленное задание и засчитывать решение любого из них

@Joker5555 · 27.05.2020, 12:23

Сообщение от ColdSkull

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

Наверное там с данными что-то не ладное, и я предполагаю, что возможно надо как-то обходить это

@mplain · 27.05.2020, 12:35

Я их послание понял так, что всё-таки у нас неправильное решение, чего-то мы не учли

Code
1
До момента написания чит-скрипта нами было получено 32 корректных решения этой задачи.

@Joker5555 · 27.05.2020, 12:39

Сообщение от mplain

Я их послание понял так, что всё-таки у нас неправильное решение, чего-то мы не учли

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

@ColdSkull · 27.05.2020, 12:54

Joker5555, Данные и функция - инты, тут ничего не придумать, иначе RE. Вполне определённый порядок, вычитал один, вычитал другой, записал, с этим тоже проблем нет.
mplain, Очень сомневаюсь, но это мы узнаем только по итогу, если они опубликуют решение, конечно

Если что-то не учли, то напишите что? Как можно писать код вслепую без требований?

@Neko-neko · 27.05.2020, 13:12

Сообщение от mplain

До момента написания чит-скрипта нами было получено 32 корректных решения этой задачи.

От 3931 человека. Кажется, задача оказалась не самая простая :)
Почти идеальная, чтобы осталось 40, которых они готовы обучать.
С другой стороны: тех, кто её решил, уже учить нечему, можно уже сразу брать на работу :)))

Добавлено через 1 минуту

Сообщение от ColdSkull

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

"Добро пожаловать в реальный мир!"? ¯\_(ツ)_/¯

("Ну пишем же...")

@Joker5555 · 27.05.2020, 13:13

Сообщение от Neko-neko

С другой стороны: тех, кто её решил, уже учить нечему, можно уже сразу брать на работу

))

может это они есть, составители задач и сотрудники

@yakanur · 27.05.2020, 18:59

Сообщение от Neko-neko

Интересно, что на это скажут те, кто и в секунду укладывался..

Мой результат
F PHP 7.3.5 OK - 285ms 2.00Mb

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

Выводил данные по Merge2Channels в stderr:
да, там 30 итераций
x1, насколько помню начитнается с 9, потом ++1
x2, начитается где-то между 250-270, потом ++3
данные поступают ровно, без задержек
fx() не тормозит
Merge2Channels запускается 2 раза

Все по памяти, хз как посмотреть старые варианты отравок.

Потратил, 70 попыток, запарился, сдаюсь =)

Когда, кажется, что все правильно вот такая ошибка

C
1
2
3
fatal error: all goroutines are asleep - deadlock!
goroutine 1 [chan receive]:
goroutine 9 [chan receive]:

Я столько горутин не создаю, значит это не мои горутины зависают, а что с этим делать хз.

Добавлено через 10 минут
добавлю, если результат писать в stderr, то все идет своим чередом

@mplain · 27.05.2020, 19:49

Code
1
fatal error: all goroutines are asleep - deadlock!

эта ошибка возникает в частности если передать слишком мало значений в out
канал продолжает ждать, а ждать нечего

Добавлено через 9 минут

Code
1
Merge2Channels запускается 2 раза

В смысле?... как ты это установил?
main запускает эту функцию дважды подряд, создаются две горутины, которые одновременно начинают посылать значения в out? И обе отрабатывают по 30 итераций? или в сумме? или они последовательно запускаются?

Новые блоги и статьи Все статьи Все блоги /
Локальный http сервер Argus19 17.10.2026 Локальный http сервер На работе, на двух локальных компьютерах круглосуточно работают программы опроса приборов с записью в книги Excel,которые раз в сутки записываются на сервер компании. Т. к. . . .	Копировать Windows на новый диск на UEFI damix 17.10.2026 https:/ / uriesk. wordpress. com/ 2016/ 11/ 01/ move-window-10-to-ssd-on-a-uefi-dualboot-system-with-basic-linux-tools/ TL DR Вставляем диск, а старый подключаем через переходник, грузимся с лайва. . .	ИИ не может найти нужный язык в списке Supersumestria 05.10.2026 Я ему даю вот такое изображение и прошу найти и подчеркнуть немецкий язык. Возвращает он вот это: https:/ / i. **********/ vqBWLe2. png Нужную строчку в 3й колонке просто выдумал. . Это. . .	Новая последняя моя музыка в SUNO zorxor 05.10.2026 Здравствуйте, дорогие мои друзья! С большой радостью я хотел бы представить вам свою новую последнею музыку, которую сгенерировала мне по моей просьбе нейросеть SUNO. С уважением, zorxor. Это. . .
Программный домашний кинотеатр russiannick 27.09.2026 Сподобился на программный домашний кинотеатр. В качестве ЯВУ по традиции выбрал js. В помощники взял Яндекс-Алису. Было создано три зала на разные интересы. исторические и ретро сериал Хичкок. . .	Беседа с ИИ о программистах, недопускающих к созданию и правке кода генеративные ИИ и причины этого zorxor 21.09.2026 Раньше я радовался или получал некоторые эмоции, пусть небольшие, но всё же, от самого процесса написания кода, рекомпиляции и запуска, видя постепенное развитие программы и прочее. А теперь лень. . .	Мобильное приложение ColorStep pavlinmavlin 17.09.2026 Реализовал приложение Красный, Зеленый, Синий в Unity3d + c#. Название изменил на ColorStep. Приложение прошло модерацию и теперь доступно для скачивания. Делал его сам, шаг за шагом — и вот,. . .	Запрет дублирования строк в табличной части Maks 13.09.2026 Реализация из решения ниже выполнена на нетиповом справочнике "Нормы ТО" с табличной часть "Виды ТО", разработанного в КА2, со следующими реквизитами: - ВидТО (СправочникСсылка. ВидыТО); - ВидГСМ. . .

@mplain 0 / 0 / 0 Регистрация: 25.05.2020 Сообщений: 12
	27.05.2020, 00:22
	Joker5555 Или можно вместо структуры завести дополнительные каналы с буфером n, обсуждалось уже такое Мне только непонятно, где здесь может быть гонка по считыванию? считыванию чего, какой переменной? 0

@mplain 0 / 0 / 0 Регистрация: 25.05.2020 Сообщений: 12
	27.05.2020, 00:38
	так нет никакой разницы по факту, считаешь ты f() параллельно или последовательно - результат одинаковый 0

@lokilo 117 / 118 / 52 Регистрация: 19.12.2014 Сообщений: 612
	27.05.2020, 05:37
	korvin_, WA - неверный ответ, но моему мнению, наебашили они охрененные тесты, которые хрен пойми, как работают 0

@ColdSkull 0 / 0 / 0 Регистрация: 23.05.2020 Сообщений: 8
	27.05.2020, 12:02
	Neko-neko, Действительно, лучше бы для Е тесты исправили. Непонятно что ему не нравится. Судя по отзывам тест на это задание в принципе не проходит, даже если оно корректно. Фиксить не будут, если боятся потерять результаты, непонятно почему бы просто не добавить ещё одно исправленное задание и засчитывать решение любого из них 0

@ColdSkull 0 / 0 / 0 Регистрация: 23.05.2020 Сообщений: 8
	27.05.2020, 12:54
	Joker5555, Данные и функция - инты, тут ничего не придумать, иначе RE. Вполне определённый порядок, вычитал один, вычитал другой, записал, с этим тоже проблем нет. mplain, Очень сомневаюсь, но это мы узнаем только по итогу, если они опубликуют решение, конечно Если что-то не учли, то напишите что? Как можно писать код вслепую без требований? 0