-
Notifications
You must be signed in to change notification settings - Fork 211
/
mutex.clj
28 lines (25 loc) · 1014 Bytes
/
mutex.clj
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
;; Copyright (c) Rich Hickey and contributors. All rights reserved.
;; The use and distribution terms for this software are covered by the
;; Eclipse Public License 1.0 (http://opensource.org/licenses/eclipse-1.0.php)
;; which can be found in the file epl-v10.html at the root of this distribution.
;; By using this software in any fashion, you are agreeing to be bound by
;; the terms of this license.
;; You must not remove this notice, or any other, from this software.
(ns ^{:skip-wiki true}
clojure.core.async.impl.mutex
(:import [java.util.concurrent.locks Lock ReentrantLock]))
(defn mutex []
(let [m (ReentrantLock.)]
(reify
Lock
(lock [_] (.lock m))
(unlock [_] (.unlock m)))))
#_(defn mutex []
(let [cas (java.util.concurrent.atomic.AtomicInteger.)]
(reify
Lock
(lock [_] (loop [got (.compareAndSet cas 0 1)]
(if got
nil
(recur (.compareAndSet cas 0 1)))))
(unlock [_] (.set cas 0)))))