вообще async $ trySome action >>= atomically . writeTMVar responseBox

где trySome :: IO a -> IO ( Either SomeException a)

а responseBox :: TMVar (Either SomeException a)

в вызывающем треде either throwM pure =<< atomically (takeTMVar response)

@termina1 ^

на сколько параллельно должно быть, зачем там async?

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

ну не важно, то что выше все равно сработает

смысл делаешь trySome в рабочем процессе результат отдаешь

в получателе при чтении делаешь either throwM pure

можно в внутрь своих методов запихать

Ок, спасибо, попробую разобраться.

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

на всякий случай уточню с какой целью ты интересуешься

имхо если нужно что то откладывать на значимое время в серверном ПО лучше это делать через редис / любое другое персистентное хранилище

@MikhailSubbotin будет жить. Поприветствуем!

на самом деле кажется мне просто нужна функия link

и в целом мой паттерн, когда мне нужно стартануть асинк, результат которого в этом треде меня не интересует, но я хочу привязать асинк к текущему треду (чтобы он пропагейтил эксепшены и убивал асинк, если тред помер) выражается как-то так withAsync action $ \a -> link a

если я ничего не перепутал

@termina1 а остальные действия треда у тебя внутри withAsync?

иначе у тебяж после линка этот асинк убъётся

может всёж действия можно как-то выразить через concurrently? Чтоб предсказуемое время жизни было?

да хотелось бы, но придется очень много переписывать

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

как я понимаю, если main-тред умрет, то все остальное помрет само

с т.зр. логики имхо лучше поставить wait на выходе main-потока

если нужно конечно иметь инфу об исключении

а не просто валиться без логов даж

ну и таймаутом, если оно потенциально может жить дольше

тебе или нужно треду вызывающему отдавать async или то что я написал

botLoop :: LogIO m => ConduitChannel -> BrainCells -> m () botLoop chan cells = do (event, pushback) <- liftIO $ readChan chan act <- liftIO $ async (do response <- processRequest cells event writeChan pushback response) liftIO $ link act botLoop chan cells

отдай тому треду, которого интересует Async и он все сделает

чем такой вариант плох?

переусложненный

но если работает то хорошо

link +1 тред форкает

waitCatch тоже поймает

но он ждать будет

вопрос корректно ли тут плодить потенциально мильон потоков если в канал могут быстро писать

обычно логично иметь "пул" обработчиков

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

ну получается тут привязка ко всем асинкам что когда либо запускал

для меня такое поведение странное

в треде который создаёт другие рабочие треды

а стоп, понял

я что-то в другую сторону про исключения думал

да, так все нормально

@qnikst а в "другую сторону" - это слать из основного в обработчики чтоль?

ну тут это делается

если основной сдох, то и обработчики

или я как всегда запутался в линках

ну получается тут привязка ко всем асинкам что когда либо запускал

Вот это верное утверждение видимо

но так как создаваемые мной треды живут очень мало, то и линки умирают достаточно быстро

тем временем стекедж-лтс опять сломан на виндовс In the dependencies for turtle-1.5.10: Win32-2.6.1.0 from stack configuration does not match >=2.2.0.1 && <2.6 (latest matching version is 2.5.4.1)

кто тут недавно говорил, что стек на виндовс работает?

Спасибо, мне как раз по работе надо знать, что там с совместимостью

@A64m_qb0 а откуда такая версия взялась? 2.5.4.1 последняя версия в стакане

c 8.4.3 видимо

(актуальная вообще 2.8 или вроде того)

а в 2.6.0 "Make cabal error out on compilation on non-Windows OSes."

наверное в этом дело

ERROR: S client not available

в 10 lts был точно такой-же баг с туртлом, я прямо старый багрепорт откопировал, только версии в нем поменял

просто стекедж никто не собирает на виндовс

и Win32 в нём нет

не совсем. на стековой странице в списке не посмотреть, да

но идущие с гхц библиотеки в нем как-бы есть (список от платформы зависит)

ну идущие с ghc идут как дефолтный набор, на который снэпшот натягивается, да

@exremi будет жить. Поприветствуем!

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

но эйзенберг немного их пыл остудил

смешно, конечно, что primitive, становясь из библиотеки для авторов библиотек более рассчитанной на простого программиста, библиотекой массивов повторил дизайн vector с сортировкой в отдельном пакете.

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

сортировать же можно по разному..

И в большинстве случаев всем плевать, как

Главное, чтобы быстро, и по возможности stable

угу

нужна в меру хорошая сортировка на данных без особого распределения

а можно как-нибудь получать нотификации об изменении в STM? (точнее блочить тред в IO пока в TVar что-нибудь не изменится)

подозреваю что придётся MVar сделать

а http://hackage.haskell.org/package/stm-2.4.5.0/docs/Control-Monad-STM.html#v:check не хватит?

а можно как-нибудь получать нотификации об изменении в STM? (точнее блочить тред в IO пока в TVar что-нибудь не изменится)

можно, но спроси точнее в чем изменения

добавляются элементы в мапу

просто можно сделать: join $ atomically $ do original <- readTVar x pure $ check (original ==) =<< readTVar x

после check .

но он каждый раз при изменении мапы будет сравнивать не с предыдущей версией

проще обернуть API для сохранения

просто можно сделать: join $ atomically $ do original <- readTVar x pure $ check (original ==) =<< readTVar x

ну это вглядит как норм метод вместо слипа

наверное он не глупый и проверяет только при наличии изменений?

да

ну insert 1 2 £ insert 1 2 - возможно проснется