PHP 進程鎖定問題分析研究

更新時間：2009年11月24日 21:38:59 作者：

剛好，前幾天也寫了一個進程鎖定的類，這個類要比上面的文章里面提到的更加強大一寫。

1. 區(qū)分讀鎖定和寫鎖定。
如果每次都使用寫鎖定，那么連多個進程讀取一個文件也要排隊，這樣的效率肯定不行。
2. 區(qū)分阻塞與非阻塞模式。
一般來說，如果一個進程在寫一個文件的時候，另外一個進程應該被阻塞，但是，很多時候，我們可以先干點別的事情，
然后再判斷一下是否有其他人在寫文件，如果沒有，再加入數據，這樣的效率更高。
3. 修復了鎖定文件在linux 上的bug，特別是在 gfs 文件系統(tǒng)上的bug。
代碼如下：

復制代碼代碼如下:

 
<?php 
class File_Lock 
{ 
private $name; 
private $handle; 
private $mode; 
function __construct($filename, $mode = 'a+b') 
{ 
global $php_errormsg; 
$this->name = $filename; 
$path = dirname($this->name); 
if ($path == '.' || !is_dir($path)) { 
global $config_file_lock_path; 
$this->name = str_replace(array("/", "\\"), array("_", "_"), $this->name); 
if ($config_file_lock_path == null) { 
$this->name = dirname(__FILE__) . "/lock/" . $this->name; 
} else { 
$this->name = $config_file_lock_path . "/" . $this->name; 
} 
} 
$this->mode = $mode; 
$this->handle = @fopen($this->name, $mode); 
if ($this->handle == false) { 
throw new Exception($php_errormsg); 
} 
} 
public function close() 
{ 
if ($this->handle !== null ) { 
@fclose($this->handle); 
$this->handle = null; 
} 
} 
public function __destruct() 
{ 
$this->close(); 
} 
public function lock($lockType, $nonBlockingLock = false) 
{ 
if ($nonBlockingLock) { 
return flock($this->handle, $lockType | LOCK_NB); 
} else { 
return flock($this->handle, $lockType); 
} 
} 
public function readLock() 
{ 
return $this->lock(LOCK_SH); 
} 
public function writeLock($wait = 0.1) 
{ 
$startTime = microtime(true); 
$canWrite = false; 
do { 
$canWrite = flock($this->handle, LOCK_EX); 
if(!$canWrite) { 
usleep(rand(10, 1000)); 
} 
} while ((!$canWrite) && ((microtime(true) - $startTime) < $wait)); 
} 
/** 
* if you want't to log the number under multi-thread system, 
* please open the lock, use a+ mod. then fopen the file will not 
* destroy the data. 
* 
* this function increment a delt value , and save to the file. 
* 
* @param int $delt 
* @return int 
*/ 
public function increment($delt = 1) 
{ 
$n = $this->get(); 
$n += $delt; 
$this->set($n); 
return $n; 
} 
public function get() 
{ 
fseek($this->handle, 0); 
return (int)fgets($this->handle); 
} 
public function set($value) 
{ 
ftruncate($this->handle, 0); 
return fwrite($this->handle, (string)$value); 
} 
public function unlock() 
{ 
if ($this->handle !== null ) { 
return flock($this->handle, LOCK_UN); 
} else { 
return true; 
} 
} 
} 
?> 

測試代碼：

復制代碼代碼如下:

 
<?php 
/** 
* 進行寫鎖定的測試 
* 打開線程1 
*/ 
require("file_lock.php"); 
$lock = new File_Lock(dirname(dirname(__FILE__)) . "/FileLock.lock"); 
/** 單個線程鎖定的速度 1s 鐘 3萬次。 **/ 
/** 兩個線程寫，兩萬的數據 大概要 7s 鐘*/ 
/** 一個線程寫，一萬的數據 大概要 3.9s 鐘，居然兩個文件同時寫，要快一點*/ 
/** 不進行鎖定，一個進程 寫大概要 2.8s 鐘，加鎖是有代價的。 */ 
/** 不進行鎖定，兩個進程 分布不是很均勻，而且大多數都沖突 */ 
$lock->writeLock(); 
$lock->increment(); 
$lock->unlock(); 
while ($lock->get() < 2) { 
usleep(1000); 
} 
sleep(1); 
echo "begin to runing \n"; 
$t1 = microtime(true); 
for ($i = 0; $i < 10000; $i++) 
{ 
$lock->writeLock(); 
$lock->increment(1); 
$lock->unlock(); 
} 
$t2 = microtime(true) - $t1; 
echo $t2; 
?> 