Update benchmark comparison.

Author: ioquatix

examples/benchmark/async-job-client.rb

@@ -0,0 +1,22 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
+
+require "active_job"
+require "async/job/adapter/active_job"
+
+class AsyncJobBenchmarkJob < ActiveJob::Base
+	self.queue_adapter = :async_job
+	queue_as :default
+	
+	def perform(index)
+		PERFORMANCE_LOG.write "{index: #{index}, start_time: #{Process.clock_gettime(Process::CLOCK_MONOTONIC)}}\n"
+		
+		sleep(0.001)
+		
+		PERFORMANCE_LOG.write "{index: #{index}, end_time: #{Process.clock_gettime(Process::CLOCK_MONOTONIC)}}\n"
+		PERFORMANCE_LOG.flush
+	end
+end

examples/benchmark/async-job-server.rb

@@ -0,0 +1,40 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
+
+require_relative "config/environment"
+
+def benchmark_async_job(job_count = 10_000)
+	puts "Benchmarking async-job with #{job_count} jobs..."
+	
+	start_time = Process.clock_gettime(Process::CLOCK_MONOTONIC)
+	
+	Sync do
+		job_count.times do |index|
+			AsyncJobBenchmarkJob.perform_later(index)
+		end
+	end
+	
+	end_time = Process.clock_gettime(Process::CLOCK_MONOTONIC)
+	
+	puts "Async-job 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_async_job(job_count)

examples/benchmark/async_job_benchmark_job.rb

@@ -0,0 +1,15 @@
+#!/usr/bin/env async-service
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024-2025, by Samuel Williams.
+# Copyright, 2025, by Shopify Inc.
+
+require_relative "config/environment"
+require "async/job/adapter/active_job/environment"
+
+service "async-job-server" do
+	include Async::Job::Adapter::ActiveJob::Environment
+	
+	count 1
+end

examples/benchmark/async_job_client.rb

@@ -0,0 +1,29 @@
+
+def performance_log_rate
+	File.open("performance.log", "r") do |file|
+		start_time = nil
+		end_time = nil
+		count = 0
+		
+		file.each_line do |line|
+			line = eval(line.strip)
+			if line[:start_time]
+				if start_time.nil? or start_time > line[:start_time]
+					start_time = line[:start_time]
+				end
+			elsif line[:end_time]
+				if end_time.nil? or end_time < line[:end_time]
+					end_time = line[:end_time]
+				end
+				count += 1
+			end
+		end
+		
+		if start_time && end_time && count > 0
+			rate = count / (end_time - start_time)
+			puts "Processed #{count} jobs at #{rate.round(2)} jobs/sec"
+		else
+			puts "No jobs processed."
+		end
+	end
+end

examples/benchmark/async_job_server.rb

@@ -7,11 +7,34 @@
 require "rails"
 require "active_job/railtie"
 require "async/job/adapter/active_job/railtie"
+require "async/job/processor/aggregate"
+require "async/job/processor/redis"
 
+ActiveJob::Base.logger = Logger.new(nil)
+PERFORMANCE_LOG = File.open("performance.log", "a")
+PERFORMANCE_LOG.sync = true
+
+# Define async-job queue for async-job adapter
 Async::Job::Adapter::ActiveJob::Railtie.define_queue "default" do
-	dequeue Async::Job::Queue::Redis
+	enqueue Async::Job::Processor::Aggregate
+	dequeue Async::Job::Processor::Redis
 end
 
-ActiveJob::Base.queue_adapter = Async::Job::Adapter::ActiveJob::Railtie.config.active_job.queue_adapter
+require "sidekiq"
+
+begin
+	require "sidekiq-pro"
+	require "sidekiq-ent"
+
+	Sidekiq::Client.reliable_push!
+
+	Sidekiq.configure_server do |config|
+		config.super_fetch!
+		config.reliable_scheduler!
+	end
+rescue LoadError
+	# Ignore.
+end
 
-require_relative "../benchmark_job"
+require_relative "../async_job_benchmark_job"
+require_relative "../sidekiq_benchmark_job"