Class: Contender::Pool::DiscardOldestPolicy

Inherits:

RejectionPolicy

• Object
• RejectionPolicy
• Contender::Pool::DiscardOldestPolicy

Defined in:

lib/contender/pool/rejection_policy.rb

Overview

Rejection policy that discards the first task in the queue and then enqueues the task

Instance Method Summary

• #on_rejection(task, executor) ⇒ undefined

Instance Method Details

#on_rejection(task, executor) ⇒ undefined

Parameters:

• task (Object)
• executor (PoolExecutor)

Returns:

• (undefined)

# File 'lib/contender/pool/rejection_policy.rb', line 53

def on_rejection(task, executor)
  return if executor.shutdown?

  executor.queue.poll
  executor.execute task
end