package.json

{
  "name": "redis-watch-test",
  "version": "1.0.0",
  "description": "",
  "main": "index.js",
  "scripts": {
    "test": "echo \"Error: no test specified\" && exit 1"
  },
  "author": "",
  "license": "ISC",
  "dependencies": {
    "redis": "^2.6.5",
    "redlock": "^2.1.0"
  }
}

redis_lock_ttl_test.js

var redis = require('redis');
var Redlock = require('redlock');

var resource = 'locks:datasetclient:myShoppingList';
var ttl = 501;


var client1 = redis.createClient();
var client2 = redis.createClient();
var client3 = redis.createClient();

console.log('create Redlock');
var redlock1 = new Redlock(
    // you should have one client for each redis node
    // in your cluster
    [client1],
    {
        retryCount:  0
    }
);

var redlock2 = new Redlock(
    // you should have one client for each redis node
    // in your cluster
    [client2],
    {
        retryCount:  0
    }
);

var redlock3 = new Redlock(
    // you should have one client for each redis node
    // in your cluster
    [client3],
    {
        retryCount:  0
    }
);

function loop(redlock, id) {
  console.log('get lock', id);
  redlock.lock(resource, ttl).then(function(lock) {
    console.log('got lock', id);
    setTimeout(function() {
      return loop(redlock, id);
    }, 500);
  }).catch(function(){
    console.log('err', id, arguments);
    setTimeout(function() {
      return loop(redlock, id);
    }, 500);
  });
}

console.log('infinite recursive loops');
setTimeout(function() {
  loop(redlock1, 1);
}, 0);
setTimeout(function() {
  loop(redlock2, 2);
}, 0);
setTimeout(function() {
  loop(redlock3, 3);
}, 0);

sample_output.txt

$ node test.js | grep "got lock"
got lock 1
got lock 1
got lock 2
got lock 1
got lock 3
got lock 3
got lock 1
got lock 3
got lock 1
got lock 1
got lock 3
got lock 1
got lock 2