class Protobuf::Rpc::SocketServer

def cleanup_threads
  log_debug "[#{log_signature}] Thread cleanup - #{@threads.size} - start"
  @threads = @threads.select do |t| 
    if t[:thread].alive? 
      true  
    else
      t[:thread].join
      @working.delete(t[:socket])
      false
    end
  end
  log_debug "[#{log_signature}] Thread cleanup - #{@threads.size} - complete"
end