clojureで慣用的なファイルロック？

Question

私はキューにファイルへの書き込みを含む先物処理ジョブのグループを持っています。 1人の未来だけが特定のファイルに一度にアクセスするようにするための慣用的な方法は何ですか？

Answer 1

これを保証するには、ロックの代わりにエージェントを使用しますか？

私は、ロックやロックを使用するよりも、メモリやディスクにあるかどうかに関係なく、安全なガード共有可変状態にすることを考えています。

一度に1つのエージェントを作成し、そのエージェントにアクセス試行を送信すると、特定のファイルにアクセスするときにスレッド上でのみ確実にアクセスできるようになります。

(use 'clojure.contrib.duck-streams) 

(defn file-agent [file-name] 
    (add-watch (agent nil) :file-writer 
    (fn [key agent old new] 
     (append-spit file-name new)))) 

(defn async-append [file-agent content] 
    (send file-agent (constantly content))) 

、エージェントを通して、あなたのファイルを追加します：

(async-append "content written to file" (file-agent "temp-file-name")) 

あなたはファイルの同期の使用が必要な場合、それはのawaitを達成することができた。このような例

。このように：

(defn sync-append [file-agent content] 
    (await (send file-agent (constantly content)))) 

Answer 2

私はClojureにこれ用の組み込み関数があるとは思っていませんが、標準のJava IO関数を使ってこれを行うことができます。これは次のようになります。

(import '(java.io File RandomAccessFile)) 

(def f (File. "/tmp/lock.file")) 
(def channel (.getChannel (RandomAccessFile. f "rw"))) 
(def lock (.lock channel)) 
(.release lock) 
(.close channel) 

Answer 3

私は次のように使用されているコアClojureの機能lockingを使用します。ここでは

(locking some-object 
    (do-whatever-you-like)) 

some-objectは、ファイル自体も、あるいはあなたが同期したい任意のオブジェクト可能性がどちらか（複数のファイルを1つのロックで保護したい場合には意味があります）。

標準ではJVMのオブジェクトロックが使用されているため、基本的にはJavaのコードブロックと同期しています。