NAME

Emilua - Lua execution engine

DESCRIPTION

local mutex = require('mutex')
local function ping_sender()


    sleep(30)


    scope(function()


        scope_cleanup_push(function() ws_write_mtx:unlock() end)


        ws_write_mtx:lock()


        ws:ping()


    end)
end
local function queue_consumer()


    scope(function()


        scope_cleanup_push(function() queue_mtx:unlock() end)


        queue_mtx:lock()


        while #queue == 0 do


            queue_cond:wait(queue_mtx)


        end


        for _, e in ipairs(queue) do


            consume_item(e)


        end


        queue = {}


    end)
end

A mutex.

FUNCTIONS

new() → mutex

Constructor.

lock(self)

Locks the mutex.

Note

This suspending function does not act as an cancellation point.

Note

This mutex applies dispatch semantics. That means no context switch to
other ready fibers will take place if it’s possible to acquire the mutex immediately.

try_lock(self) → boolean

Tries to lock the mutex. Returns whether lock acquisition was successful.

Caution

It’s an error to call try_lock() if current fiber already owns the
mutex (cf. recursive_mutex(3em) for an alternative).

Note

The current fiber is never suspended.

unlock(self)

Unlocks the mutex.