Retry :: STM a

@Curry · Регистрация: 01.06.2013

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

На hackage сказано про эту функцию, что она : "Retry execution of the current memory transaction because it has seen values in TVars which mean that it should not continue (e.g. the TVars represent a shared buffer that is now empty). "
А в небезизвестной книжке Real World Haskell написано : "The STM API provides a retry action which will immediately terminate an atomically block that cannot proceed." Хм. Retry, это, вроде, ну ни как не terminate?
На самом, деле, вроде бы, всё просто:

Haskell
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import System.IO
import Control.Monad
import Control.Concurrent.STM
import Control.Concurrent
 
main = do
    tv  <- atomically (newTVar  0)
    forkIO $ do 
        threadDelay 3000000
        putStrLn "After threadDelay"
        hFlush stdout
        atomically ( writeTVar tv 1 )
    atomically $ do
        v  <- readTVar tv
        when (v==0) retry
    putStrLn "Finish"
    hFlush stdout

- создаём TVar с начальным значением 0, Заускаем трэд, в котором через 3 секунды установим эту переменную в 1. Пока тред ждёт свои 3 секунды, создаём (срока 13) транзакцию, в которой читаем эту переменную, и если она ==0 выполняем таинственную retry.
Результат работы программы:

Code
1
2
3
4
*Main> :main
After threadDelay
Finish
*Main>

- перед сообщением "After threadDelay" была задержка в 3 секунды. И, вроде, бы нам становится понятно, что retry перезапускает целую транзакцию когда трэд изменит tv. Однако, добавим отладочной печати и прочего чтобы выяснить в чём дело :

Haskell
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
import System.IO
import Control.Monad
import Control.Concurrent.STM
import Control.Concurrent
import Debug.Trace
 
main = do
    tv  <- atomically (newTVar  0)
    tv0 <- atomically (newTVar 0)
    forkIO $ do 
        threadDelay 3000000
        putStrLn "After threadDelay"
        hFlush stdout
        atomically ( writeTVar tv 1 )
    atomically $ do
        traceM $ "atomically beg"
        v0 <- readTVar tv0
        traceM $ "v0=" ++ show v0
        traceM $ "before readTVar tv"
        v  <- readTVar tv
        traceM $ "v=" ++ show v
        when (v==0) retry
        traceM $ "atomically end"
    putStrLn "Finish"
    hFlush stdout

Результат:

Code
1
2
3
4
5
6
7
8
9
10
11
12
*Main> :main
atomically beg
v0=0
before readTVar tv
v=0
v0=0
before readTVar tv
v=1
atomically end
After threadDelay
Finish
*Main>

Первый раз транзакция выполняется до изменения tv, т.е. задержка после первой строки v=0 (строка 5 листинга результата).
Дальше интересно. Ну, что сообщения через putStrLn выводятся позже тех что через traceM, это ладно. Вобщем, в треде выполняется writeTVar tv 1 и транзакция "как бы" перезапускается. Именно, как бы. Первого сообщения из неё : "atomically beg" повторно нет. Появляются (стр. 6-8) "v0=0","before readTVar tv" и "v=1". Всё верно - tv теперь /=0, retry не выполняется и транзакция завершается - "atomically end".

Одно не понятно - почему не выдаётся первое сообщение из транзакции при повторе : "atomically beg". Если переставить местами чтение tv0 и tv - ничего не изменится. Саму tv0 я ввёл т.к. была гипотеза что повтор начинается просто с последней функции readTVar - не подтвердилось.

p.s. Ежели "знатоки" других языков захотят сказать, мол, а вот у нас ... То мы, на эти инсинуации ответим, что, в Haskell- хвала монадам, есть много способов синхронизации потоков. Однако, хочется понять и этот.

Новые блоги и статьи Все статьи Все блоги /
Автозаполнение реквизита при выборе элемента справочника Maks 27.03.2026 Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .	Сумматор с применением элементов трёх состояний. Hrethgir 26.03.2026 Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .	Автозаполнение реквизитов при создании документа Maks 26.03.2026 Программный код из решения ниже размещается в модуле объекта документа, в процедуре "ПриСозданииНаСервере". Алгоритм проверки заполнения реализован для исключения перезаписи значения реквизита,. . .	Команды формы и диалоговое окно Maks 26.03.2026 1. Команда формы "ЗаполнитьЗапчасти". Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. В качестве источника данных. . .
Кому нужен AOT? DevAlt 26.03.2026 Решил сделать простой ланчер Написал заготовку: dotnet new console --aot -o UrlHandler var items = args. Split(":"); var tag = items; var id = items; var executable = args;. . .	Отправка уведомления на почту при изменении наименования справочника Maks 24.03.2026 Программная отправка письма электронной почты на примере изменения наименования типового справочника "Склады" в конфигурации БП3. Перед реализацией необходимо выполнить настройку системной учетной. . .	модель ЗдравоСохранения 5. Меньше увольнений- больше дохода! anaschu 24.03.2026 Теперь система здравосохранения уменьшает количество увольнений. 9TO2GP2bpX4 a42b81fb172ffc12ca589c7898261ccb/ https:/ / rutube. ru/ video/ a42b81fb172ffc12ca589c7898261ccb/ Слева синяя линия -. . .	Midnight Chicago Blues kumehtar 24.03.2026 Такой Midnight Chicago Blues, знаешь?. . Когда вечерние улицы становятся ночными, а ты не можешь уснуть. Ты идёшь в любимый старый бар, и бармен наливает тебе виски. Ты смотришь на пролетающие. . .