| # Get reasonable CLI confirmation before continuing. | |
| # | |
| # @param text [String] - the descriptive text | |
| # @param options [Hash{Symbol=>Object}] | |
| # @option options [Boolean] :default - the default action (false) | |
| # @option options [#puts] :out - the IO on which to puts output ($stderr) | |
| # @option options [#readline] :in - the IO on which to readline input ($stdin) | |
| # @option options [String] :prompt - the prompt string ("ok?") | |
| # | |
| # @example |
| $ ruby ~/Desktop/sleepy.rb | |
| signals registered. | |
| ^CCAUGHT INT! | |
| 4 |
| # encoding: utf-8 | |
| # | |
| # DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE | |
| # Version 2, December 2004 | |
| # | |
| # Copyright (C) 2004 Ryan Biesemeyer <wtf@yaauie.com> | |
| # | |
| # Everyone is permitted to copy and distribute verbatim or modified | |
| # copies of this license document, and changing it is allowed as long | |
| # as the name is changed. |
| require 'thread' # Mutex | |
| require 'monitor' # MonitorMixin::ConditionVariable | |
| # A semaphore that supports Read Locks, Write Locks, and Sized Semaphores | |
| class Yaauie::Semaphore | |
| INFINITY = Float::INFINITY | |
| # @param options [Hash{Symbol=>Object}] | |
| # @option options [Integer, INFINITY] :readers_max (INFINITY) | |
| def initialize(options = {}) |
| def time_thread_contention(options = {}) | |
| thread_count = options.fetch(:threads, 10) | |
| iterations = options.fetch(:iterations, 10) | |
| start_time = Time.now | |
| iterations.times.each_slice(thread_count).to_a.transpose.map do |idxs| | |
| Thread.new do | |
| idxs.each do |idx| | |
| yield | |
| Thread.pass if idx.odd? |
| # @param search [String, Regexp] | |
| # @yieldparam time [Time] | |
| # @yieldparam payload [String] | |
| # @yieldreurn [void] | |
| # @return [void] | |
| def find_delayed_jobs(search) | |
| return enum_for(__method__, search) unless block_given? | |
| min = 0 | |
| max = '+inf' |
| # encoding: utf-8 | |
| require 'openssl' | |
| class EasyKrypt | |
| class Error < RuntimeError | |
| def initialize(*args) | |
| @cause = $! | |
| end | |
| attr_reader :cause |
| #!/usr/bin/env ruby | |
| # gi - a dynamic alias for poorly-typed git commands | |
| # handle a command `gi tdiff --cached`, | |
| # transparently as `git diff --cached`. | |
| exit(127) if ARGV.empty? | |
| exit(127) unless ARGV.first.start_with?('t') | |
| argv = ARGV.dup | |
| argv.unshift(argv.shift[1..-1]) |
Sometimes your redis needs a little help keeping up with expiries.
First, it's helpful to know how expiries are handled in redis internals:
Redis keys are expired in two ways: a passive way, and an active way.
A key is actively expired simply when some client tries to access it, and the key is found to be timed out.