Add SolidQueue benchmark.

Author: ioquatix

examples/benchmark/config/database.yml

@@ -0,0 +1,22 @@
+# SQLite database configuration for SolidQueue
+# This is a minimal setup for benchmarking purposes
+
+development: &default
+  adapter: sqlite3
+  database: db/development.sqlite3
+  pool: <%= ENV.fetch("RAILS_MAX_THREADS") { 5 } %>
+  timeout: 5000
+
+# SolidQueue needs a separate database connection
+# You can use the same database with different connection name
+solid_queue:
+  <<: *default
+  database: db/solid_queue.sqlite3
+
+test:
+  <<: *default
+  database: db/test.sqlite3
+
+production:
+  <<: *default
+  database: db/production.sqlite3

examples/benchmark/config/environment.rb

@@ -36,5 +36,13 @@
 	# Ignore.
 end
 
+# SolidQueue support
+begin
+	require "solid_queue"
+rescue LoadError
+	puts "SolidQueue not available - install with: gem install solid_queue"
+end
+
 require_relative "../async_job_benchmark_job"
 require_relative "../sidekiq_benchmark_job"
+require_relative "../solid_queue_benchmark_job"

examples/benchmark/gems.rb

@@ -19,3 +19,7 @@
 gem "async-job-processor-redis"
 gem "async-job-adapter-active_job"
 gem "async-service"
+
+# SolidQueue support
+gem "solid_queue"
+gem "sqlite3"

examples/benchmark/setup_solid_queue.rb

@@ -0,0 +1,64 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
+
+# Setup script for SolidQueue database
+
+require "active_record"
+require "logger"
+
+# Connect to SQLite database
+ActiveRecord::Base.establish_connection(
+  adapter: 'sqlite3',
+  database: 'db/solid_queue.sqlite3'
+)
+
+ActiveRecord::Base.logger = Logger.new(STDOUT)
+
+# Create SolidQueue tables
+ActiveRecord::Schema.define do
+  # Core job storage table
+  create_table :solid_queue_jobs, if_not_exists: true do |t|
+    t.string :job_class, null: false
+    t.text :job_args, null: false
+    t.string :queue_name, null: false
+    t.integer :priority, default: 0, null: false
+    t.timestamp :scheduled_at
+    t.timestamp :finished_at
+    
+    t.timestamps null: false
+    
+    t.index [:queue_name, :priority, :scheduled_at], name: "index_solid_queue_jobs_for_polling"
+    t.index [:scheduled_at], name: "index_solid_queue_jobs_on_scheduled_at"
+    t.index [:finished_at], name: "index_solid_queue_jobs_on_finished_at"
+  end
+  
+  # Process tracking table
+  create_table :solid_queue_processes, if_not_exists: true do |t|
+    t.string :name, null: false
+    t.string :hostname, null: false
+    t.integer :pid, null: false
+    t.timestamp :last_heartbeat_at, null: false
+    
+    t.timestamps null: false
+    
+    t.index [:name], unique: true
+    t.index [:last_heartbeat_at]
+  end
+  
+  # Failed jobs table
+  create_table :solid_queue_failed_executions, if_not_exists: true do |t|
+    t.references :job, null: false, foreign_key: { to_table: :solid_queue_jobs }
+    t.text :exception_class
+    t.text :exception_message
+    t.text :backtrace
+    
+    t.timestamps null: false
+  end
+end
+
+puts "SolidQueue database tables created successfully!"
+puts "Database: db/solid_queue.sqlite3"

examples/benchmark/sidekiq_benchmark_job.rb

@@ -1,7 +1,8 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2025, by Samuel Williams.
+# Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
 
 require "active_job"
 

examples/benchmark/sidekiq_server.rb

@@ -3,6 +3,7 @@
 
 # Released under the MIT License.
 # Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
 
 require_relative "config/environment"
 

examples/benchmark/solid_queue_benchmark_job.rb

@@ -0,0 +1,13 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
+
+class SolidQueueBenchmarkJob
+	# Simple plain Ruby job class (no ActiveJob inheritance)
+	def perform
+		sleep(0.001)
+		puts "[solid_queue] Job performed at: #{Process.clock_gettime(Process::CLOCK_MONOTONIC)}"
+	end
+end

examples/benchmark/solid_queue_client.rb

@@ -0,0 +1,87 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
+
+# Create a minimal Rails-like environment for SolidQueue
+ENV['RAILS_ENV'] ||= 'development'
+
+require "bundler/setup"
+require "rails"
+require "active_job/railtie"
+require "active_record/railtie"
+
+# Create a minimal Rails application
+class SolidQueueApp < Rails::Application
+  config.load_defaults 7.1
+  config.eager_load = false
+  config.logger = Logger.new(nil) # Quiet for client
+  config.log_level = :error
+  
+  # Don't configure ActiveJob for our simple database queue
+end
+
+# Initialize the Rails app
+Rails.application.initialize!
+
+# Set up database connection - use correct path in benchmark directory
+database_path = File.join(__dir__, 'db', 'solid_queue.sqlite3')
+puts "Connecting to database: #{database_path}"
+
+ActiveRecord::Base.establish_connection(
+  adapter: 'sqlite3',
+  database: database_path
+)
+
+# Simple database-backed job model (instead of complex SolidQueue setup)
+class SimpleSolidJob < ActiveRecord::Base
+  self.table_name = 'solid_queue_jobs'
+end
+
+# Clear ActiveRecord cache and verify connection
+ActiveRecord::Base.clear_cache!
+puts "Database connection: #{ActiveRecord::Base.connection.database_version}"
+puts "Tables available: #{ActiveRecord::Base.connection.tables.join(', ')}"
+
+# Load our job
+require_relative "solid_queue_benchmark_job"
+
+def benchmark_solid_queue(job_count = 10_000)
+	puts "Benchmarking solid_queue with #{job_count} jobs..."
+	
+	start_time = Process.clock_gettime(Process::CLOCK_MONOTONIC)
+	
+	job_count.times do
+		# Insert job directly into database instead of using ActiveJob
+		SimpleSolidJob.create!(
+			job_class: 'SolidQueueBenchmarkJob',
+			job_args: '[]',
+			queue_name: 'solid_queue_default',
+			priority: 0,
+			created_at: Time.current,
+			updated_at: Time.current
+		)
+	end
+	
+	end_time = Process.clock_gettime(Process::CLOCK_MONOTONIC)
+	
+	puts "SolidQueue results:"
+	puts "  Started at: #{start_time}"
+	puts "  Ended at: #{end_time}"
+	puts "  Total enqueue time: #{end_time - start_time}s"
+	puts "  Jobs per second: #{(job_count / (end_time - start_time)).round(2)}"
+end
+
+# Parse command line argument for job count
+job_count = ARGV[0] ? ARGV[0].to_i : 10_000
+
+if job_count <= 0
+	puts "Error: Job count must be a positive integer"
+	puts "Usage: #{$0} [job_count]"
+	puts "Example: #{$0} 5000"
+	exit 1
+end
+
+benchmark_solid_queue(job_count)

examples/benchmark/solid_queue_server.rb

@@ -0,0 +1,96 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
+
+# Create a minimal Rails-like environment for SolidQueue
+ENV['RAILS_ENV'] ||= 'development'
+
+require "bundler/setup"
+require "rails"
+require "active_job/railtie"
+require "active_record/railtie"
+
+# Create a minimal Rails application
+class SolidQueueApp < Rails::Application
+  config.load_defaults 7.1
+  config.eager_load = false
+  config.logger = Logger.new(STDOUT)
+  config.log_level = :info
+  
+  # Database is configured via establish_connection
+  
+  # Don't configure ActiveJob for our simple database queue
+end
+
+# Initialize the Rails app
+Rails.application.initialize!
+
+# Set up database connection - use correct path in benchmark directory
+database_path = File.join(__dir__, 'db', 'solid_queue.sqlite3')
+puts "Server connecting to database: #{database_path}"
+
+ActiveRecord::Base.establish_connection(
+  adapter: 'sqlite3',
+  database: database_path
+)
+
+# Simple database-backed job model (instead of complex SolidQueue setup)
+class SimpleSolidJob < ActiveRecord::Base
+  self.table_name = 'solid_queue_jobs'
+end
+
+# Load our job  
+require_relative "solid_queue_benchmark_job"
+
+puts "Starting SolidQueue server..."
+puts "Processing queue: solid_queue_default"
+puts "Database: #{File.expand_path('../db/solid_queue.sqlite3', __dir__)}"
+puts "Press Ctrl+C to stop"
+
+# Simple worker loop using ActiveRecord  
+def process_jobs
+  loop do
+    # Fetch unprocessed jobs
+    job = SimpleSolidJob.where(queue_name: 'solid_queue_default', finished_at: nil)
+                       .order(:created_at)
+                       .first
+    
+    if job
+      begin
+        puts "Processing job #{job.id}: #{job.job_class}"
+        
+        # Execute the job
+        job_class = job.job_class.constantize
+        job_args = JSON.parse(job.job_args)
+        job_class.new.perform(*job_args)
+        
+        # Mark as finished
+        job.update!(finished_at: Time.current)
+        puts "Job #{job.id} completed"
+        
+      rescue => e
+        puts "Job #{job.id} failed: #{e.message}"
+        job.update!(finished_at: Time.current) # Mark as finished even if failed
+      end
+    else
+      sleep(0.1) # Poll every 100ms
+    end
+  end
+end
+
+# Handle graceful shutdown
+trap("INT") do
+  puts "\nShutting down SolidQueue server..."
+  exit
+end
+
+trap("TERM") do
+  puts "\nShutting down SolidQueue server..."
+  exit
+end
+
+# Start processing
+process_jobs