compress_test.rb

  def tc_deflate!( set )
    # Single thread / core only!
    cur=@tc.size/2
    cached={}
    set.map! {|elem|
      unless (idx=@tc[elem]) #already there
        cur+=1
        cached[cur]=elem
        cached[elem]=cur
        Integer( cur )
      else
        Integer( idx )
      end
    }
    @tc.update cached
    set
  end

  def redis_store( word )
    # Safe concurrent access to the Redis DB
    loop do
      @redis.watch("words")
      value = @redis.hget("words", word)
      @redis.unwatch and break(value) if value
      idx = (@redis.hlen("words")/2).to_s
      break(idx) if @redis.multi do
        @redis.hmset("words", word, idx, idx, word)
      end
    end
  end