-- | Lifted "Control.Concurrent.MVar.Strict".
--
-- @since 2.4.0.0
module Effectful.Concurrent.MVar.Strict
  ( -- * Effect
    Concurrent

    -- ** Handlers
  , runConcurrent

    -- * MVar
  , MVar'
  , newEmptyMVar'
  , newMVar'
  , takeMVar'
  , putMVar'
  , readMVar'
  , swapMVar'
  , tryTakeMVar'
  , tryPutMVar'
  , tryReadMVar'
  , isEmptyMVar'
  , withMVar'
  , withMVar'Masked
  , modifyMVar'
  , modifyMVar'_
  , modifyMVar'Masked
  , modifyMVar'Masked_
  , mkWeakMVar'
  ) where

import System.Mem.Weak (Weak)
import Control.Concurrent.MVar.Strict (MVar')
import Control.Concurrent.MVar.Strict qualified as M

import Effectful
import Effectful.Concurrent.Effect
import Effectful.Dispatch.Static
import Effectful.Dispatch.Static.Primitive
import Effectful.Dispatch.Static.Unsafe

-- | Lifted 'M.newEmptyMVar''.
newEmptyMVar' :: Concurrent :> es => Eff es (MVar' a)
newEmptyMVar' :: forall (es :: [Effect]) a. (Concurrent :> es) => Eff es (MVar' a)
newEmptyMVar' = IO (MVar' a) -> Eff es (MVar' a)
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ IO (MVar' a)
forall a. IO (MVar' a)
M.newEmptyMVar'

-- | Lifted 'M.newMVar''.
newMVar' :: Concurrent :> es => a -> Eff es (MVar' a)
newMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
a -> Eff es (MVar' a)
newMVar' = IO (MVar' a) -> Eff es (MVar' a)
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO (MVar' a) -> Eff es (MVar' a))
-> (a -> IO (MVar' a)) -> a -> Eff es (MVar' a)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> IO (MVar' a)
forall a. a -> IO (MVar' a)
M.newMVar'

-- | Lifted 'M.takeMVar''.
takeMVar' :: Concurrent :> es => MVar' a -> Eff es a
takeMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> Eff es a
takeMVar' = IO a -> Eff es a
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO a -> Eff es a) -> (MVar' a -> IO a) -> MVar' a -> Eff es a
forall b c a. (b -> c) -> (a -> b) -> a -> c
. MVar' a -> IO a
forall a. MVar' a -> IO a
M.takeMVar'

-- | Lifted 'M.putMVar''.
putMVar' :: Concurrent :> es => MVar' a -> a -> Eff es ()
putMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> a -> Eff es ()
putMVar' MVar' a
var = IO () -> Eff es ()
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO () -> Eff es ()) -> (a -> IO ()) -> a -> Eff es ()
forall b c a. (b -> c) -> (a -> b) -> a -> c
. MVar' a -> a -> IO ()
forall a. MVar' a -> a -> IO ()
M.putMVar' MVar' a
var

-- | Lifted 'M.readMVar''.
readMVar' :: Concurrent :> es => MVar' a -> Eff es a
readMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> Eff es a
readMVar' = IO a -> Eff es a
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO a -> Eff es a) -> (MVar' a -> IO a) -> MVar' a -> Eff es a
forall b c a. (b -> c) -> (a -> b) -> a -> c
. MVar' a -> IO a
forall a. MVar' a -> IO a
M.readMVar'

-- | Lifted 'M.swapMVar''.
swapMVar' :: Concurrent :> es => MVar' a -> a -> Eff es a
swapMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> a -> Eff es a
swapMVar' MVar' a
var = IO a -> Eff es a
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO a -> Eff es a) -> (a -> IO a) -> a -> Eff es a
forall b c a. (b -> c) -> (a -> b) -> a -> c
. MVar' a -> a -> IO a
forall a. MVar' a -> a -> IO a
M.swapMVar' MVar' a
var

-- | Lifted 'M.tryTakeMVar''.
tryTakeMVar' :: Concurrent :> es => MVar' a -> Eff es (Maybe a)
tryTakeMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> Eff es (Maybe a)
tryTakeMVar' = IO (Maybe a) -> Eff es (Maybe a)
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO (Maybe a) -> Eff es (Maybe a))
-> (MVar' a -> IO (Maybe a)) -> MVar' a -> Eff es (Maybe a)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. MVar' a -> IO (Maybe a)
forall a. MVar' a -> IO (Maybe a)
M.tryTakeMVar'

-- | Lifted 'M.tryPutMVar''.
tryPutMVar' :: Concurrent :> es => MVar' a -> a -> Eff es Bool
tryPutMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> a -> Eff es Bool
tryPutMVar' MVar' a
var = IO Bool -> Eff es Bool
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO Bool -> Eff es Bool) -> (a -> IO Bool) -> a -> Eff es Bool
forall b c a. (b -> c) -> (a -> b) -> a -> c
. MVar' a -> a -> IO Bool
forall a. MVar' a -> a -> IO Bool
M.tryPutMVar' MVar' a
var

-- | Lifted 'M.tryReadMVar''.
tryReadMVar' :: Concurrent :> es => MVar' a -> Eff es (Maybe a)
tryReadMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> Eff es (Maybe a)
tryReadMVar' = IO (Maybe a) -> Eff es (Maybe a)
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO (Maybe a) -> Eff es (Maybe a))
-> (MVar' a -> IO (Maybe a)) -> MVar' a -> Eff es (Maybe a)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. MVar' a -> IO (Maybe a)
forall a. MVar' a -> IO (Maybe a)
M.tryReadMVar'

-- | Lifted 'M.isEmptyMVar''.
isEmptyMVar' :: Concurrent :> es => MVar' a -> Eff es Bool
isEmptyMVar' :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> Eff es Bool
isEmptyMVar' = IO Bool -> Eff es Bool
forall a (es :: [Effect]). IO a -> Eff es a
unsafeEff_ (IO Bool -> Eff es Bool)
-> (MVar' a -> IO Bool) -> MVar' a -> Eff es Bool
forall b c a. (b -> c) -> (a -> b) -> a -> c
. MVar' a -> IO Bool
forall a. MVar' a -> IO Bool
M.isEmptyMVar'

-- | Lifted 'M.withMVar''.
withMVar' :: Concurrent :> es => MVar' a -> (a -> Eff es b) -> Eff es b
withMVar' :: forall (es :: [Effect]) a b.
(Concurrent :> es) =>
MVar' a -> (a -> Eff es b) -> Eff es b
withMVar' MVar' a
var a -> Eff es b
f = ((forall r. Eff es r -> IO r) -> IO b) -> Eff es b
forall (es :: [Effect]) a.
((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
reallyUnsafeUnliftIO (((forall r. Eff es r -> IO r) -> IO b) -> Eff es b)
-> ((forall r. Eff es r -> IO r) -> IO b) -> Eff es b
forall a b. (a -> b) -> a -> b
$ \forall r. Eff es r -> IO r
unlift -> do
  MVar' a -> (a -> IO b) -> IO b
forall a b. MVar' a -> (a -> IO b) -> IO b
M.withMVar' MVar' a
var ((a -> IO b) -> IO b) -> (a -> IO b) -> IO b
forall a b. (a -> b) -> a -> b
$ Eff es b -> IO b
forall r. Eff es r -> IO r
unlift (Eff es b -> IO b) -> (a -> Eff es b) -> a -> IO b
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> Eff es b
f
{-# INLINE withMVar' #-}

-- | Lifted 'M.withMVar'Masked'.
withMVar'Masked :: Concurrent :> es => MVar' a -> (a -> Eff es b) -> Eff es b
withMVar'Masked :: forall (es :: [Effect]) a b.
(Concurrent :> es) =>
MVar' a -> (a -> Eff es b) -> Eff es b
withMVar'Masked MVar' a
var a -> Eff es b
f = ((forall r. Eff es r -> IO r) -> IO b) -> Eff es b
forall (es :: [Effect]) a.
((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
reallyUnsafeUnliftIO (((forall r. Eff es r -> IO r) -> IO b) -> Eff es b)
-> ((forall r. Eff es r -> IO r) -> IO b) -> Eff es b
forall a b. (a -> b) -> a -> b
$ \forall r. Eff es r -> IO r
unlift -> do
  MVar' a -> (a -> IO b) -> IO b
forall a b. MVar' a -> (a -> IO b) -> IO b
M.withMVar'Masked MVar' a
var ((a -> IO b) -> IO b) -> (a -> IO b) -> IO b
forall a b. (a -> b) -> a -> b
$ Eff es b -> IO b
forall r. Eff es r -> IO r
unlift (Eff es b -> IO b) -> (a -> Eff es b) -> a -> IO b
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> Eff es b
f
{-# INLINE withMVar'Masked #-}

-- | Lifted 'M.modifyMVar'_'.
modifyMVar'_ :: Concurrent :> es => MVar' a -> (a -> Eff es a) -> Eff es ()
modifyMVar'_ :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> (a -> Eff es a) -> Eff es ()
modifyMVar'_ MVar' a
var a -> Eff es a
f = ((forall r. Eff es r -> IO r) -> IO ()) -> Eff es ()
forall (es :: [Effect]) a.
((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
reallyUnsafeUnliftIO (((forall r. Eff es r -> IO r) -> IO ()) -> Eff es ())
-> ((forall r. Eff es r -> IO r) -> IO ()) -> Eff es ()
forall a b. (a -> b) -> a -> b
$ \forall r. Eff es r -> IO r
unlift -> do
  MVar' a -> (a -> IO a) -> IO ()
forall a. MVar' a -> (a -> IO a) -> IO ()
M.modifyMVar'_ MVar' a
var ((a -> IO a) -> IO ()) -> (a -> IO a) -> IO ()
forall a b. (a -> b) -> a -> b
$ Eff es a -> IO a
forall r. Eff es r -> IO r
unlift (Eff es a -> IO a) -> (a -> Eff es a) -> a -> IO a
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> Eff es a
f
{-# INLINE modifyMVar'_ #-}

-- | Lifted 'M.modifyMVar''.
modifyMVar' :: Concurrent :> es => MVar' a -> (a -> Eff es (a, b)) -> Eff es b
modifyMVar' :: forall (es :: [Effect]) a b.
(Concurrent :> es) =>
MVar' a -> (a -> Eff es (a, b)) -> Eff es b
modifyMVar' MVar' a
var a -> Eff es (a, b)
f = ((forall r. Eff es r -> IO r) -> IO b) -> Eff es b
forall (es :: [Effect]) a.
((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
reallyUnsafeUnliftIO (((forall r. Eff es r -> IO r) -> IO b) -> Eff es b)
-> ((forall r. Eff es r -> IO r) -> IO b) -> Eff es b
forall a b. (a -> b) -> a -> b
$ \forall r. Eff es r -> IO r
unlift -> do
  MVar' a -> (a -> IO (a, b)) -> IO b
forall a b. MVar' a -> (a -> IO (a, b)) -> IO b
M.modifyMVar' MVar' a
var ((a -> IO (a, b)) -> IO b) -> (a -> IO (a, b)) -> IO b
forall a b. (a -> b) -> a -> b
$ Eff es (a, b) -> IO (a, b)
forall r. Eff es r -> IO r
unlift (Eff es (a, b) -> IO (a, b))
-> (a -> Eff es (a, b)) -> a -> IO (a, b)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> Eff es (a, b)
f
{-# INLINE modifyMVar' #-}

-- | Lifted 'M.modifyMVar'Masked_'.
modifyMVar'Masked_ :: Concurrent :> es => MVar' a -> (a -> Eff es a) -> Eff es ()
modifyMVar'Masked_ :: forall (es :: [Effect]) a.
(Concurrent :> es) =>
MVar' a -> (a -> Eff es a) -> Eff es ()
modifyMVar'Masked_ MVar' a
var a -> Eff es a
f = ((forall r. Eff es r -> IO r) -> IO ()) -> Eff es ()
forall (es :: [Effect]) a.
((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
reallyUnsafeUnliftIO (((forall r. Eff es r -> IO r) -> IO ()) -> Eff es ())
-> ((forall r. Eff es r -> IO r) -> IO ()) -> Eff es ()
forall a b. (a -> b) -> a -> b
$ \forall r. Eff es r -> IO r
unlift -> do
  MVar' a -> (a -> IO a) -> IO ()
forall a. MVar' a -> (a -> IO a) -> IO ()
M.modifyMVar'Masked_ MVar' a
var ((a -> IO a) -> IO ()) -> (a -> IO a) -> IO ()
forall a b. (a -> b) -> a -> b
$ Eff es a -> IO a
forall r. Eff es r -> IO r
unlift (Eff es a -> IO a) -> (a -> Eff es a) -> a -> IO a
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> Eff es a
f
{-# INLINE modifyMVar'Masked_ #-}

-- | Lifted 'M.modifyMVar'Masked'.
modifyMVar'Masked :: Concurrent :> es => MVar' a -> (a -> Eff es (a, b)) -> Eff es b
modifyMVar'Masked :: forall (es :: [Effect]) a b.
(Concurrent :> es) =>
MVar' a -> (a -> Eff es (a, b)) -> Eff es b
modifyMVar'Masked MVar' a
var a -> Eff es (a, b)
f = ((forall r. Eff es r -> IO r) -> IO b) -> Eff es b
forall (es :: [Effect]) a.
((forall r. Eff es r -> IO r) -> IO a) -> Eff es a
reallyUnsafeUnliftIO (((forall r. Eff es r -> IO r) -> IO b) -> Eff es b)
-> ((forall r. Eff es r -> IO r) -> IO b) -> Eff es b
forall a b. (a -> b) -> a -> b
$ \forall r. Eff es r -> IO r
unlift -> do
  MVar' a -> (a -> IO (a, b)) -> IO b
forall a b. MVar' a -> (a -> IO (a, b)) -> IO b
M.modifyMVar'Masked MVar' a
var ((a -> IO (a, b)) -> IO b) -> (a -> IO (a, b)) -> IO b
forall a b. (a -> b) -> a -> b
$ Eff es (a, b) -> IO (a, b)
forall r. Eff es r -> IO r
unlift (Eff es (a, b) -> IO (a, b))
-> (a -> Eff es (a, b)) -> a -> IO (a, b)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. a -> Eff es (a, b)
f
{-# INLINE modifyMVar'Masked #-}

-- | Lifted 'M.mkWeakMVar''.
--
-- /Note:/ the finalizer will run a cloned environment, so any changes it makes
-- to thread local data will not be visible outside of it.
mkWeakMVar'
  :: (HasCallStack, Concurrent :> es)
  => MVar' a -> Eff es ()
  -> Eff es (Weak (MVar' a))
mkWeakMVar' :: forall (es :: [Effect]) a.
(HasCallStack, Concurrent :> es) =>
MVar' a -> Eff es () -> Eff es (Weak (MVar' a))
mkWeakMVar' MVar' a
var Eff es ()
f = (Env es -> IO (Weak (MVar' a))) -> Eff es (Weak (MVar' a))
forall (es :: [Effect]) a. (Env es -> IO a) -> Eff es a
unsafeEff ((Env es -> IO (Weak (MVar' a))) -> Eff es (Weak (MVar' a)))
-> (Env es -> IO (Weak (MVar' a))) -> Eff es (Weak (MVar' a))
forall a b. (a -> b) -> a -> b
$ \Env es
es -> do
  -- The finalizer can run at any point and in any thread.
  MVar' a -> IO () -> IO (Weak (MVar' a))
forall a. MVar' a -> IO () -> IO (Weak (MVar' a))
M.mkWeakMVar' MVar' a
var (IO () -> IO (Weak (MVar' a)))
-> (Env es -> IO ()) -> Env es -> IO (Weak (MVar' a))
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Eff es () -> Env es -> IO ()
forall (es :: [Effect]) a. Eff es a -> Env es -> IO a
unEff Eff es ()
f (Env es -> IO (Weak (MVar' a)))
-> IO (Env es) -> IO (Weak (MVar' a))
forall (m :: Type -> Type) a b. Monad m => (a -> m b) -> m a -> m b
=<< Env es -> IO (Env es)
forall (es :: [Effect]). HasCallStack => Env es -> IO (Env es)
cloneEnv Env es
es