Control.Concurrent.MVar

data SkipChan a = SkipChan (MVar (a, [MVar ()])) (MVar ())

newSkipChan :: IO (SkipChan a)
newSkipChan = do
    sem <- newEmptyMVar
    main <- newMVar (undefined, [sem])
    return (SkipChan main sem)

putSkipChan :: SkipChan a -> a -> IO ()
putSkipChan (SkipChan main _) v = do
    (_, sems) <- takeMVar main
    putMVar main (v, [])
    mapM_ (\sem -> putMVar sem ()) sems

getSkipChan :: SkipChan a -> IO a
getSkipChan (SkipChan main sem) = do
    takeMVar sem
    (v, sems) <- takeMVar main
    putMVar main (v, sem : sems)
    return v

dupSkipChan :: SkipChan a -> IO (SkipChan a)
dupSkipChan (SkipChan main _) = do
    sem <- newEmptyMVar
    (v, sems) <- takeMVar main
    putMVar main (v, sem : sems)
    return (SkipChan main sem)

data MVar a Source

MVar (произносится "эм-вар") — это синхронизирующая переменная, используемая для связи между конкурирующими потоками. Можно представить её как ящик, который может быть пустым или заполненным.

newEmptyMVar :: IO (MVar a) Source

Создать MVar, который изначально пуст.

newMVar :: a -> IO (MVar a) Source

Создать MVar, который содержит предоставленное значение.

takeMVar :: MVar a -> IO a Source

Возвращает содержимое MVar. Если MVar в настоящее время пуст, takeMVar будет ожидать, пока он не заполнится. После takeMVar, MVar остаётся пустым.

Есть ещё две важные особенности takeMVar:

• takeMVar — это однократное пробуждение. То есть, если несколько потоков заблокированы в takeMVar, и MVar заполняется, только один поток будет разбужен. Система выполнения гарантирует, что разбуженный поток завершит свою операцию takeMVar.
• Когда несколько потоков заблокированы на MVar, они разбуживаются в порядке очереди «первый пришёл — первый обслужен». Это полезно для обеспечения справедливости абстракций, созданных с использованием MVar.

putMVar :: MVar a -> a -> IO () Source

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

Есть ещё две важные особенности putMVar:

• putMVar — это однократное пробуждение. То есть, если несколько потоков заблокированы в putMVar, и MVar становится пустым, только один поток будет разбужен. Система выполнения гарантирует, что разбуженный поток завершит свою операцию putMVar.
• Когда несколько потоков заблокированы на MVar, они разбуживаются в порядке очереди «первый пришёл — первый обслужен». Это полезно для обеспечения справедливости абстракций, созданных с использованием MVar.

readMVar :: MVar a -> IO a Source

Атомарно прочитать содержимое MVar. Если MVar в настоящее время пуст, readMVar будет ожидать, пока он не заполнится. readMVar гарантированно получит следующее putMVar.

readMVar — это многократное пробуждение, поэтому когда несколько читателей заблокированы на MVar, все они разбуживаются одновременно. Система выполнения гарантирует, что все разбуженные потоки завершат свою операцию readMVar.

Примечание по совместимости: До версии base 4.7, readMVar был комбинацией takeMVar и putMVar. Это означало, что при наличии других потоков, пытающихся putMVar, readMVar мог заблокироваться. Кроме того, readMVar не получал бы следующий putMVar, если уже был заблокирован ожидающий поток на takeMVar. Старое поведение можно восстановить, реализовав `readMVar` следующим образом:

readMVar :: MVar a -> IO a
readMVar m =
  mask_ $ do
    a <- takeMVar m
    putMVar m a
    return a

swapMVar :: MVar a -> a -> IO a Источник

Извлечь значение из MVar, поместить новое значение в MVar и вернуть извлечённое значение. Эта функция атомарна только если нет других производителей для этого MVar. Другими словами, она не может гарантировать, что к моменту, когда swapMVar получит возможность записи в MVar, значение MVar не будет изменено операцией записи из другого потока.

tryTakeMVar :: MVar a -> IO (Maybe a) Источник

Неблокирующая версия takeMVar. Функция tryTakeMVar возвращается немедленно, с Nothing, если MVar была пустой, или с Just a, если MVar была полной с содержимым a. После tryTakeMVar, MVar остаётся пустой.

tryPutMVar :: MVar a -> a -> IO Bool Источник

Неблокирующая версия putMVar. Функция tryPutMVar пытается поместить значение a в MVar, возвращая True при успехе или False в противном случае.

isEmptyMVar :: MVar a -> IO Bool Источник

Проверить, пуст ли данный MVar.

Обратите внимание, что возвращаемое булево значение — это просто мгновенный снимок состояния MVar. К моменту, когда вы среагируете на его результат, MVar может быть заполнен (или опустошен) — будьте очень осторожны при использовании этой операции. Используйте tryTakeMVar вместо этого, если это возможно.

withMVar :: MVar a -> (a -> IO b) -> IO b Источник

withMVar — это защищённая от исключений обёртка для работы со содержимым MVar. Эта операция защищена от исключений: она заменит исходное содержимое MVar в случае возникновения исключения (см. Control.Exception). Однако она атомарна только если нет других производителей для этого MVar. Другими словами, она не может гарантировать, что к моменту, когда withMVar получит возможность записи в MVar, значение MVar не будет изменено операцией записи из другого потока.

withMVarMasked :: MVar a -> (a -> IO b) -> IO b Источник

Как withMVar, но действие IO во втором аргументе выполняется с замаскированными асинхронными исключениями.

С: base-4.7.0.0

modifyMVar_ :: MVar a -> (a -> IO a) -> IO () Источник

Защищённая от исключений обёртка для изменения содержимого MVar. Как и withMVar, modifyMVar заменит исходное содержимое MVar в случае возникновения исключения во время операции. Эта функция атомарна только если нет других производителей для этого MVar. Другими словами, она не может гарантировать, что к моменту, когда modifyMVar_ получит возможность записи в MVar, значение MVar не будет изменено операцией записи из другого потока.

modifyMVar :: MVar a -> (a -> IO (a, b)) -> IO b Источник

Небольшая вариация modifyMVar_ которая позволяет вернуть значение (b) в дополнение к изменённому значению MVar.

modifyMVarMasked_ :: MVar a -> (a -> IO a) -> IO () Источник

Как modifyMVar_, но действие IO во втором аргументе выполняется с замаскированными асинхронными исключениями.

С: base-4.6.0.0

modifyMVarMasked :: MVar a -> (a -> IO (a, b)) -> IO b Источник

Как modifyMVar, но действие IO во втором аргументе выполняется с замаскированными асинхронными исключениями.

С: base-4.6.0.0

tryReadMVar :: MVar a -> IO (Maybe a) Источник

Неблокирующая версия readMVar. Функция tryReadMVar возвращается немедленно, с Nothing, если MVar была пустой, или с Just a, если MVar была полной с содержимым a.

С: base-4.7.0.0

mkWeakMVar :: MVar a -> IO () -> IO (Weak (MVar a)) Источник

Создать указатель Weak на MVar, используя второй аргумент как финализатор для выполнения, когда MVar будет собран сборщиком мусора.

С: base-4.6.0.0

addMVarFinalizer :: MVar a -> IO () -> IO () Источник