Feature: Add lifecycle hooks for Threads about workers HOT 3 CLOSED

# Create a custom worker class.
# This class represents a single event driven thread.
class MyWorker < Workers::Worker
  private

  def shutdown_handler(event)
    disconnect_db
    super
  end

  def perform_handler(event)
    connect_db
    super
  end

  def connect_db
    # Open the DB connection if it doesn't exist.
    puts "connect_db() called."
  end

  def disconnect_db
    # Close the DB connection if it exists.
    puts "disconnect_db() called."
  end
end

# Create a pool with 10 custom workers.
exception_handler = proc { |e|
  puts "Don't forget to handle your exceptions..."
  puts "Exception: #{e.class}: #{e.message}\n#{e.backtrace.join("\n")}"
}
pool = Workers::Pool.new(:worker_class => MyWorker, :on_exception => exception_handler)
pool.perform do
  puts "Hello World!"
end
pool.shutdown