Skip to content

Instantly share code, notes, and snippets.

@tomheng

tomheng/gist:6149779

Last active May 21, 2019 08:21
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save tomheng/6149779 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save tomheng/6149779 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. tomheng revised this gist Aug 6, 2013. 1 changed file with 2 additions and 2 deletions.
    4 changes: 2 additions & 2 deletions gistfile1.php
    View file
    Original file line number Diff line number Diff line change
    @@ -16,7 +16,7 @@ class Lock{
    */
    public function __construct(){
    if(function_exists('memcache_init')){
    $this->mc = memcache_init();
    $this->mc = memcache_connect('memcache_host', 11211);
    }
    }

    @@ -49,7 +49,7 @@ public function begin($name, $block = true)
    //$this->debug();
    break;
    }else{
    dolog('Lock failed '.$name);
    //dolog('Lock failed '.$name);
    }
    //echo '#'.PHP_EOL;
    //sleep(1);
  2. tomheng renamed this gist Aug 4, 2013. 1 changed file with 0 additions and 0 deletions.
    0 memcache_lock_service → gistfile1.php
    View file
    File renamed without changes.
  3. tomheng revised this gist Aug 4, 2013. No changes.
  4. tomheng created this gist Aug 4, 2013.
    104 changes: 104 additions & 0 deletions memcache_lock_service
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,104 @@
    <?php

    /**
    * 锁服务(用Memcache模拟锁)
    */

    class Lock{

    private $mc = null;
    private $key_prefix = "memcache_lock_service_key_";
    private $all_lock_names = array();
    private $expiration = 60; //one min
    private $max_block_time = 15; //最长的阻塞时间
    /**
    * [__construct description]
    */
    public function __construct(){
    if(function_exists('memcache_init')){
    $this->mc = memcache_init();
    }
    }

    /**
    * [get_key description]
    * @param [type] $name [description]
    * @return [type] [description]
    */
    private function get_key($name){
    $key = $this->key_prefix.$name;
    return $key;
    }

    /**
    * 捕获锁
    * @param [type] $name [description]
    * @return [type] [description]
    */
    public function begin($name, $block = true)
    {
    if(!$this->mc || !$name){
    return false;
    }
    $max_block_time = $this->max_block_time;
    $key = $this->get_key($name);
    do{
    $re = memcache_add($this->mc, $key, 1, false, $this->expiration);
    if($re == true){
    $this->all_lock_names[$name] = 1;
    //$this->debug();
    break;
    }else{
    dolog('Lock failed '.$name);
    }
    //echo '#'.PHP_EOL;
    //sleep(1);
    }while($block && $max_block_time-- && !sleep(1));
    return $re;
    }

    /**
    * 释放锁
    */
    public function release($name){
    if(!$this->mc || !$name){
    return false;
    }
    $key = $this->get_key($name);
    $re = memcache_delete($this->mc, $key);
    if($re == true){
    unset($this->all_lock_names[$name]);
    }
    return $re;
    }

    /**
    * 释放所有的锁
    */
    public function __destruct(){
    if(!$this->mc){
    return false;
    }
    foreach ($this->all_lock_names as $name => $value) {
    # code...
    $this->release($name);
    }
    }

    /**
    * 调试
    * @return [type] [description]
    */
    public function debug(){
    var_dump($this->all_lock_names);
    foreach ($this->all_lock_names as $name => $value) {
    $key = $this->get_key($name);
    if($this->mc){
    $value = memcache_get($this->mc, $key);
    }else{
    $value = "no such lock ";
    }
    echo "Lock name:$key, value:{$value}".PHP_EOL;
    }
    }
    }