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 Источник

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

newEmptyMVar :: IO (MVar a) Источник

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

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

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

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

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

Есть две другие важные особенности takeMVar:

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

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

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

Есть две другие важные особенности putMVar:

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

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

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

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

Примечание о совместимости: До версии 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 Source

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

tryTakeMVar :: MVar a -> IO (Maybe a) Source

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

tryPutMVar :: MVar a -> a -> IO Bool Source

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

isEmptyMVar :: MVar a -> IO Bool Source

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

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

withMVar :: MVar a -> (a -> IO b) -> IO b Source

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

withMVarMasked :: MVar a -> (a -> IO b) -> IO b Source

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

Since: base-4.7.0.0

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

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

modifyMVar :: MVar a -> (a -> IO (a, b)) -> IO b Source

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

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

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

Since: base-4.6.0.0

modifyMVarMasked :: MVar a -> (a -> IO (a, b)) -> IO b Source

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

Since: base-4.6.0.0

tryReadMVar :: MVar a -> IO (Maybe a) Source

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

Since: base-4.7.0.0

mkWeakMVar :: MVar a -> IO () -> IO (Weak (MVar a)) Source

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

Since: base-4.6.0.0

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