redis_mutex.rb

def Redis.Mutex(name, expires:, redis: Redis.current, &block)
	raise ArgumentError, "block required" unless block_given?

	if block.arity.zero?
		success = block
		block = proc do |on|
			on.success(&success)
			on.failure(&proc{})
		end
	end

	result =
		if Redis.current.set("mutex:#{name}", Time.current.iso8601, nx: true, ex: expires.seconds)
			M.Success(name)
		else
			M.Failure(name)
		end

	Dry::Matcher::ResultMatcher.(result, &block)
ensure
	Redis.current.del("mutex:#{name}") if result.success?
end