gistfile1.txt

class RedisLock
  class << self
    def with_lock(name, wait: false)
      key = "LOCK:#{name}"
      until fetch_lock(key)
        if wait
          sleep(1)
        else
          return
        end
      end

      begin
        Timeout.timeout(13) do # timeout in 13 seconds and delete the lock
          yield
        end
      ensure
        $redis.del(key)
      end
    end

    def fetch_lock(key)
      $redis.set(key, 1, nx: true, px: 15_000) # expires in 15 seconds
    end
  end
end