原子創建一個文件鎖定在MATLAB（文件互斥）

Question

我正在尋找一個簡單的已經實現的解決方案，在MATLAB中原子創建一個文件鎖定。

喜歡的東西：

file_lock('create', 'mylockfile'); %this will block until it creates the lock file. 
file_lock('remove', 'mylockfile'); %this will remove the lock file: 

這個問題已經被問了好幾次，一些提出的解決思路（比如使用Java FileLock）， 但我沒有找到一個簡單的已經實施的解決方案。

你知道這樣一個實施的解決方案嗎？

注：

• locking file access OR exchanging messages bw Matlab Instances
• Thread Subject: Safe file mutex without race condition

Answer 1

寫入到一個新的文件，然後將其重命名。重命名是一個原子操作，所有新內容將立即變爲可見。

Answer 2

最後我做了一個基於兩個連續測試（移動文件，並驗證移動文件的內容）的實現。

寫得不是很好，但它現在適用於我。

+++++ file_lock.m ++++++++++++++++++++++++

function file_lock(op, filename) 
%this will block until it creates the lock file: 
%file_lock('create', 'mylockfile') 
% 
%this will remove the lock file: 
%file_lock('remove', 'mylockfile') 


% todo: verify that there are no bugs 

filename = [filename '.mat']; 

if isequal(op, 'create') 
    id = [tempname() '.mat'] 
    while true 
    save(id, 'id'); 
    success = fileattrib(id, '-w'); 
    if success == 0; error('fileattrib'); end 

    while true 
     if exist(filename, 'file');  %first test 
     fprintf('file lock exists(1). waiting...\n'); 
     pause(1); 
     continue; 
     end 
     status = movefile(id, filename); %second test 
     if status == 1; break; end 
     fprintf('file lock exists(2). waiting...\n'); 
     pause(1); 
    end 

    temp = load(filename, 'id');   % third test. 
    if isequal(id, temp.id); break; end 

    fprintf('file lock exists(3). waiting...\n'); 
    pause(1) 
    end 

elseif isequal(op, 'remove') 
    %delete(filename); 
    execute_rs(@() delete(filename)); 

else 
    error('invalid op'); 
end 



function execute_rs(f) 
while true 
    try 
    lastwarn(''); 
    f(); 
    if ~isequal(lastwarn, ''); error(lastwarn); end %such as: Warning: File not found or permission denied 
    break; 
    catch exception 
    fprintf('Error: %s\n.Retrying...\n', exception.message); 
    pause(.5); 
    end 
end 

+++++++ +++++++++++++++++++++++

Answer 3

我已經解決了一個非常簡單的解決方案錯誤/將來自多個工作線程的消息記錄到單個文件中。每次我想寫入該文件時，首先將輸出寫入該線程自己的臨時文件。接下來，我使用flock將該臨時文件追加到「主」日誌文件中。這裏跳過一些細節，這個想法是：

fid=fopen(threadtemp, 'w'); 
fprintf(fid, 'Error message goes here'); 
fclose(fid); 

runme = sprintf('flock -x %s -c ''cat %s >> %s''', LOGFILE, threadtemp, LOGFILE); 
system(runme); 

詳見羊羣手冊頁，但調用以上，取得該日誌文件的獨佔鎖，鎖下運行所提供的命令，然後將其釋放。

這顯然只適用於一個有flock的系統（Linux/OS X，並且只有某些類型的文件系統），而且你正在做一些可以從命令行完成的工作，但我敢打賭，這是一個非常常見的用例。

Answer 4

根據其Java版本你正在使用，也許這將工作（從翻譯：http://www.javabeat.net/2007/10/locking-files-using-java/）

classdef FileLock < handle 
    properties (Access = private) 
     fileLock = [] 
     file 
    end 

    methods 
     function this = FileLock(filename) 
      this.file = java.io.RandomAccessFile(filename,'rw'); 
      fileChannel = this.file.getChannel(); 
      this.fileLock = fileChannel.tryLock(); 
     end 

     function val = hasLock(this) 
      if ~isempty(this.fileLock) && this.fileLock.isValid() 
       val = true; 
      else 
       val = false; 
      end 
     end 

     function delete(this) 
      this.release(); 
     end 

     function release(this) 
      if this.hasLock 
       this.fileLock.release(); 
      end 
      this.file.close 
     end 
    end 
end 

用法是：

lock = FileLock('my_lock_file'); 
if lock.hasLock 
    %// do something here 
else 
    %// I guess not 
end 
%// Manually release the lock, or just delete (or let matlab clean it up) 

我喜歡IO obj的包裝模式因此即使在例外情況下也可以釋放

編輯：必須將文件參考文件保留在周圍並手動關閉，否則您將無法編輯該文件。這意味着這個代碼只對純鎖文件有用，我想。

Answer 5

如果你只需要在OS X和Linux版本（非Windows）上運行，你可以使用以下命令：

pathLock='/tmp/test.lock' 

% Try to create and lock this file. 
% In my case I use -r 0 to avoid retrying 
% You could use -r -1 to retry forever, or for a particular amount of time, 
% etc, see `man lockfile` for details. 
if ~system(sprintf('lockfile -r 0 %s',pathLock)) 
    % We succeeded, so perform some task which needs to be serialized. 
    % runSerializedTask() 
    % Now remove the lockfile 
    system(sprintf('rm -f %s',pathLock)); 
end