Added reentrant locks module to stdlib
This commit is contained in:
parent
2e3c403d2b
commit
0290bc2240
2 changed files with 63 additions and 1 deletions
50
lib/core/rlocks.nim
Normal file
50
lib/core/rlocks.nim
Normal file
|
|
@ -0,0 +1,50 @@
|
|||
#
|
||||
#
|
||||
# Nim's Runtime Library
|
||||
# (c) Copyright 2015 Andreas Rumpf
|
||||
#
|
||||
# See the file "copying.txt", included in this
|
||||
# distribution, for details about the copyright.
|
||||
#
|
||||
|
||||
## This module contains Nim's support for reentrant locks
|
||||
|
||||
include "system/syslocks"
|
||||
|
||||
type
|
||||
RLock* = SysLock ## Nim lock, re-entrant
|
||||
|
||||
proc initRLock*(lock: var RLock) {.inline.} =
|
||||
## Initializes the given lock.
|
||||
when defined(posix):
|
||||
var a: SysLockAttr
|
||||
initSysLockAttr(a)
|
||||
setSysLockType(a, SysLockType_Reentrant())
|
||||
initSysLock(lock, a.addr)
|
||||
else:
|
||||
initSysLock(lock)
|
||||
|
||||
proc deinitRLock*(lock: var RLock) {.inline.} =
|
||||
## Frees the resources associated with the lock.
|
||||
deinitSys(lock)
|
||||
|
||||
proc tryAcquire*(lock: var RLock): bool =
|
||||
## Tries to acquire the given lock. Returns `true` on success.
|
||||
result = tryAcquireSys(lock)
|
||||
|
||||
proc acquire*(lock: var RLock) =
|
||||
## Acquires the given lock.
|
||||
acquireSys(lock)
|
||||
|
||||
proc release*(lock: var RLock) =
|
||||
## Releases the given lock.
|
||||
releaseSys(lock)
|
||||
|
||||
template withRLock*(lock: var RLock, code: stmt): stmt =
|
||||
## Acquires the given lock and then executes the code
|
||||
block:
|
||||
acquire(lock)
|
||||
defer:
|
||||
release(lock)
|
||||
{.locks: [lock].}:
|
||||
code
|
||||
|
|
@ -75,12 +75,24 @@ else:
|
|||
type
|
||||
SysLock {.importc: "pthread_mutex_t", pure, final,
|
||||
header: "<sys/types.h>".} = object
|
||||
SysLockAttr {.importc: "pthread_mutexattr_t", pure, final
|
||||
header: "<sys/types.h>".} = object
|
||||
SysCond {.importc: "pthread_cond_t", pure, final,
|
||||
header: "<sys/types.h>".} = object
|
||||
SysLockType = distinct cint
|
||||
|
||||
proc initSysLock(L: var SysLock, attr: pointer = nil) {.
|
||||
proc SysLockType_Reentrant: SysLockType =
|
||||
{.emit: "`result` = PTHREAD_MUTEX_RECURSIVE;".}
|
||||
|
||||
proc initSysLock(L: var SysLock, attr: ptr SysLockAttr = nil) {.
|
||||
importc: "pthread_mutex_init", header: "<pthread.h>", noSideEffect.}
|
||||
|
||||
proc initSysLockAttr(a: var SysLockAttr) {.
|
||||
importc: "pthread_mutexattr_init", header: "<pthread.h>", noSideEffect.}
|
||||
|
||||
proc setSysLockType(a: var SysLockAttr, t: SysLockType) {.
|
||||
importc: "pthread_mutexattr_settype", header: "<pthread.h>", noSideEffect.}
|
||||
|
||||
proc acquireSys(L: var SysLock) {.noSideEffect,
|
||||
importc: "pthread_mutex_lock", header: "<pthread.h>".}
|
||||
proc tryAcquireSysAux(L: var SysLock): cint {.noSideEffect,
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue