Add client request benchmark/comparison.

Author: ioquatix

benchmark/async/http/client.rb

@@ -0,0 +1,90 @@
+# frozen_string_literal: true
+
+require "sus/fixtures/async/http"
+require "sus/fixtures/benchmark"
+require "net/http"
+require "uri"
+
+describe Async::HTTP::Client do
+	include Sus::Fixtures::Async::HTTP::ServerContext
+	include Sus::Fixtures::Benchmark
+	
+	let(:count) {100}
+	
+	RESPONSE_DATA = "x" * 1024 * 1024 * 2 # 2MB
+	
+	def app
+		Protocol::HTTP::Middleware.for do |request|
+			# sleep 0.001 # Simulate some work.
+			
+			Protocol::HTTP::Response[
+				200,
+				{
+					"content-type" => "text/plain",
+					"cache-control" => "no-cache, no-store",
+				},
+				RESPONSE_DATA
+			]
+		end
+	end
+	
+	with Thread do
+		measure Net::HTTP do |repeats|
+			uri = URI(self.bound_url)
+			repeats.times do
+				threads = []
+				
+				count.times do
+					threads << Thread.new do
+						http = Net::HTTP.new(uri.host, uri.port)
+						
+						response = http.get("/")
+						response.body.length
+					ensure
+						http.finish rescue nil
+					end
+				end
+				
+				threads.each(&:join)
+			end
+		end
+	end
+	
+	with Async do
+		measure Net::HTTP do |repeats|
+			uri = URI(self.bound_url)
+			repeats.times do
+				tasks = []
+				
+				count.times do
+					tasks << Async do
+						http = Net::HTTP.new(uri.host, uri.port)
+						
+						response = http.get("/")
+						
+					ensure
+						http.finish rescue nil
+					end
+				end
+				
+				results = tasks.map(&:wait)
+			end
+		end
+		
+		measure Async::HTTP do |repeats|
+			repeats.times do
+				tasks = []
+				
+				count.times do
+					tasks << Async do
+						response = client.get("/")
+						body = response.read
+						body.length
+					end
+				end
+				
+				results = tasks.map(&:wait)
+			end
+		end
+	end
+end