class Concurrent::Agent

def ns_find_last_job_for_thread
  @queue.rindex { |job| job.caller == Thread.current.object_id }
end