khóa tập tin thành ngữ trong clojure?

Question

Tôi có một nhóm các công việc xử lý tương lai từ một hàng đợi liên quan đến việc ghi vào các tệp. Cách thành ngữ để đảm bảo chỉ một tương lai truy cập vào một tệp cụ thể tại một thời điểm là gì?

Answer 1

Cách sử dụng tác nhân thay vì khóa để đảm bảo điều này?

Tôi nghĩ rằng việc sử dụng tác nhân để bảo vệ an toàn được chia sẻ trạng thái có thể thay đổi, bất kể nó có trong bộ nhớ hoặc trên đĩa có nhiều thành ngữ trong clojure hơn là sử dụng khóa hay không.

Nếu bạn tạo một tác nhân tại một thời điểm và gửi quyền truy cập vào đại lý, bạn có thể đảm bảo rằng chỉ trên chuỗi tại thời điểm truy cập tệp đã cho.

Ví dụ như thế này:

(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))) 

sau đó nối tập tin của bạn thông qua các đại lý:

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

Nếu bạn cần sử dụng đồng bộ các tập tin nó có thể đạt được với chờ đợi. Như thế này:

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

Answer 2

Tôi không nghĩ rằng có chức năng tích hợp cụ thể cho điều này trong Clojure nhưng bạn có thể sử dụng các hàm IO java tiêu chuẩn để thực hiện việc này. Điều này sẽ trông giống như sau:

(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

Tôi sẽ sử dụng lõi Clojure chức năng locking được sử dụng như sau:

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

Đây some-object hoặc có thể là các tập tin riêng của mình, hoặc cách khác bất kỳ đối tượng tùy ý mà bạn muốn đồng bộ hóa trên (có thể có ý nghĩa nếu bạn muốn có một khóa duy nhất để bảo vệ nhiều tệp).

Phía dưới nắp này sử dụng khóa đối tượng JVM tiêu chuẩn, do đó về cơ bản nó tương đương với một khối mã được đồng bộ trong Java.