Cache::Memcached::Semaphore - a simple pure-perl library for cross-machine semaphores using memcached.

	use Cache::Memcached;
	use Cache::Memcached::Semaphore;

	my $memd = new Cache::Memcached {
		'servers' => [ "10.0.0.15:11211", "10.0.0.15:11212",
						"10.0.0.17:11211", [ "10.0.0.17:11211", 3 ] ],
	};

	# OO interface
	# acquire semaphore
	my $lock = Cache::Memcached::Semaphore(
		memd => $memd, 
		name => "semaphore1",
	);
	# release semaphore
	$lock = undef;

	# acquire semaphore which will stay 10 secs after deleting object
	my $lock2 = Cache::Memcached::Semaphore(
		memd => $memd, 
		name => "semaphore2",
		timeout => 10,
	);

	# Functional interface
	# acquire semaphore which will stay 10 secs after deleting object
	my $lock3 = acquire(
		memd => $memd, 
		name => "semaphore3",
		timeout => 10,
	);

	# try to acquire semaphore during 10 seconds
	my $lock4 = wait_acquire(
		memd => $memd, 
		name => "semaphore4",
		max_wait	=> 10,
		poll_time	=> 0.1,
	);

	

This module uses Cache::Memcached perl API to maintain semaphores across a number of servers. It relies upon return value of memcached API add function (true in case of previously non-existent value, false in case value already exists).

Tested with memcached v 1.1.12, Cache::Memcached 1.15+ on FreeBSD 6.0-RELEASE, 6.1-STABLE, 6.1-RELEASE, 6.2-PRERELEASE.

new

Takes a hash of named options. The main keys are memd which is a reference to a memcached API object (actually, it can be any blessed reference with the same interface as Cache::Memcached) and name - the name for the semaphore.

Use timeout to set the time in seconds, for which acquiring the semaphore will be impossible after releasing it.

The constructor return a blessed reference to Cache::Memcached::Semaphore object in case of success, otherwise undef.

The semaphore is released automatically when the variable holding the reference to the object leaves the scope or is explicitly set to any other value (in the object's destructor).

acquire

Takes the same parameters as the constructor and returns blessed object reference in case of success, otherwise undef.

wait_acquire

Takes the same options as above plus extra two: max_wait and poll_time. The function tries to acquire the semaphore, in case of failure it waits poll_time seconds (may be fractions of seconds) and tries again. If the function succeeds to acquire the semafore within max_wait seconds, it returns a blessed object reference. Otherwise it returns undef.

None known yet

Forced lock acquiring

Semaphore time-to-live

Deadlock resolving

Sergei A. Fedorov <zmij@cpan.org>

I will be happy to have your feedback about the module.

This module is Copyright (c) 2006 Sergei A. Fedorov. All rights reserved.

You may distribute under the terms of either the GNU General Public License or the Artistic License, as specified in the Perl README file.

This is free software. IT COMES WITHOUT WARRANTY OF ANY KIND.