Falcon Web Server: Async Ruby in Production

# Gemfile
gem 'falcon', '~> 0.47'

bundle install
bundle exec falcon serve --bind http://0.0.0.0:3000

# The async stack powering Falcon
require 'async'              # Core event loop and fiber scheduling
require 'async-container'    # Multi-process container management
require 'async-http'         # HTTP/1.1 and HTTP/2 protocol support
require 'async-websocket'    # Native WebSocket support

# Memory comparison (approximate)
Thread.new { sleep 1 }   # ~8KB per thread
Fiber.new { sleep 1 }    # ~4KB per fiber + shared stack

# This is safe in Falcon (single-threaded per process)
@connection_count ||= 0
@connection_count += 1

# No need for locks or thread-safe data structures
@cache = {}  # Safe to use regular Hash

# In a Falcon application
def expensive_api_call
  # This will yield to other fibers
  Net::HTTP.get(uri)  # Non-blocking in async context
end

def database_query
  # This will also yield
  User.find(params[:id])  # Non-blocking with async adapter
end

# HTTP/2 server push example
def call(env)
  if env['HTTP_ACCEPT']&.include?('text/html')
    # Push critical resources
    env['falcon.push']&.call('/assets/app.css')
    env['falcon.push']&.call('/assets/app.js')
  end

  [200, {}, ['Hello World']]
end

# Gemfile
gem 'falcon', '~> 0.47'

# For Rails applications
gem 'rails', '~> 7.0'
group :production do
  gem 'falcon'
end

$ bundle install

# config.ru
require 'json'

class HelloApp
  def call(env)
    case env['PATH_INFO']
    when '/'
      [200, {'Content-Type' => 'text/html'}, ['<h1>Hello, Falcon!</h1>']]
    when '/json'
      data = { message: 'Hello from Falcon', timestamp: Time.now.iso8601 }
      [200, {'Content-Type' => 'application/json'}, [data.to_json]]
    when '/slow'
      # Simulate slow I/O - other requests continue processing
      sleep(2)  # This yields to other fibers in Falcon
      [200, {'Content-Type' => 'text/plain'}, ['Slow response completed']]
    else
      [404, {}, ['Not Found']]
    end
  end
end

run HelloApp.new

# Development (with self-signed HTTPS)
$ falcon serve

# Production binding
$ falcon serve --bind http://0.0.0.0:3000

# Custom configuration
$ bundle exec falcon host

# Falcon's Railtie sets this for you wherever the gem is loaded
config.active_support.isolation_level = :fiber

# config/falcon.rb
#!/usr/bin/env falcon-host

load :rack

hostname = File.basename(__dir__)
port = ENV.fetch('PORT', 3000)

rack hostname, :self_signed_tls do
  append preload "config/environment"

  # Production optimizations
  cache_control :public, max_age: 3600

  # Process configuration
  count ENV.fetch('WEB_CONCURRENCY', 4).to_i
end

# Bind to specific interface in production
endpoint Async::HTTP::Endpoint.parse("http://0.0.0.0:#{port}")

# app.rb
require 'sinatra/base'
require 'json'

class AsyncApp < Sinatra::Base
  configure :production do
    set :server, :falcon
    set :bind, '0.0.0.0'
    set :port, ENV.fetch('PORT', 4567)
  end

  get '/' do
    'Hello from Falcon + Sinatra!'
  end

  get '/stream' do
    content_type 'text/event-stream'

    # Server-sent events work great with Falcon
    stream do |out|
      10.times do |i|
        out << "data: Event #{i}\n\n"
        sleep 0.5  # Yields to other fibers
      end
      out << "data: Complete\n\n"
    end
  end

  get '/api/users/:id' do
    # Simulate async database call
    user_data = fetch_user_async(params[:id])
    content_type :json
    user_data.to_json
  end

  private

  def fetch_user_async(id)
    # This would be a real async database call
    sleep(0.1)  # Simulated I/O that yields
    { id: id, name: "User #{id}", created_at: Time.now }
  end
end

# config/falcon.rb
#!/usr/bin/env falcon-host

load :rack

# Environment-based configuration
environment = ENV.fetch('RAILS_ENV', 'development')
hostname = ENV.fetch('HOSTNAME', 'localhost')
port = ENV.fetch('PORT', 3000).to_i
workers = ENV.fetch('WEB_CONCURRENCY', 4).to_i

# SSL configuration for production
if environment == 'production'
  ssl_certificate_path = ENV.fetch('SSL_CERTIFICATE_PATH')
  ssl_private_key_path = ENV.fetch('SSL_PRIVATE_KEY_PATH')

  service hostname do
    include Falcon::Environment::Rack
    include Falcon::Environment::SSL

    ssl_certificate ssl_certificate_path
    ssl_private_key ssl_private_key_path

    count workers
    endpoint Async::HTTP::Endpoint.parse("https://0.0.0.0:#{port}")

    # Rails application
    append preload "config/environment"
  end
else
  # Development configuration with self-signed cert
  rack hostname, :self_signed_tls do
    append preload "config/environment"
    count 2  # Less processes for development
    endpoint Async::HTTP::Endpoint.parse("https://#{hostname}:#{port}")
  end
end

# .env.production
RAILS_ENV=production
WEB_CONCURRENCY=8
PORT=3000
HOSTNAME=myapp.com

# SSL Configuration
SSL_CERTIFICATE_PATH=/etc/ssl/certs/myapp.crt
SSL_PRIVATE_KEY_PATH=/etc/ssl/private/myapp.key

# Database and Redis should support async operations
DATABASE_POOL_SIZE=25
REDIS_POOL_SIZE=25

# Memory and GC optimization
RUBY_GC_HEAP_INIT_SLOTS=600000
RUBY_GC_HEAP_FREE_SLOTS=600000
RUBY_GC_HEAP_GROWTH_FACTOR=1.25
RUBY_GC_MALLOC_LIMIT=64000000

# /etc/systemd/system/myapp-falcon.service
[Unit]
Description=MyApp Falcon Server
After=network.target

[Service]
Type=exec
User=deploy
Group=deploy
WorkingDirectory=/var/www/myapp
Environment=RAILS_ENV=production
EnvironmentFile=/var/www/myapp/.env.production

ExecStart=/usr/local/bin/bundle exec falcon host
ExecReload=/bin/kill -USR2 $MAINPID

Restart=always
RestartSec=5
StandardOutput=journal
StandardError=journal
SyslogIdentifier=myapp-falcon

# Security
NoNewPrivileges=true
PrivateTmp=true

# Resource limits
LimitNOFILE=65536
LimitNPROC=4096

[Install]
WantedBy=multi-user.target

FROM ruby:3.2-alpine

# Install dependencies
RUN apk add --no-cache \
    build-base \
    postgresql-dev \
    nodejs \
    yarn \
    tzdata \
    curl

WORKDIR /app

# Copy dependency files
COPY Gemfile Gemfile.lock ./
RUN bundle config set --local deployment 'true' && \
    bundle config set --local without 'development test' && \
    bundle install

# Copy application
COPY . .

# Compile assets
RUN RAILS_ENV=production rails assets:precompile

# Create non-root user
RUN addgroup -g 1001 -S falcon && \
    adduser -u 1001 -S falcon -G falcon

# Switch to non-root user
USER falcon

# Expose port
EXPOSE 3000

# Health check
HEALTHCHECK --interval=30s --timeout=10s --start-period=60s --retries=3 \
  CMD curl -f http://localhost:3000/health || exit 1

# Start server
CMD ["bundle", "exec", "falcon", "host"]

# k8s/deployment.yaml
apiVersion: apps/v1
kind: Deployment
metadata:
  name: myapp-falcon
spec:
  replicas: 3
  selector:
    matchLabels:
      app: myapp-falcon
  template:
    metadata:
      labels:
        app: myapp-falcon
    spec:
      containers:
      - name: falcon
        image: myapp:latest
        ports:
        - containerPort: 3000
        env:
        - name: RAILS_ENV
          value: "production"
        - name: WEB_CONCURRENCY
          value: "4"
        - name: PORT
          value: "3000"
        resources:
          requests:
            memory: "256Mi"
            cpu: "250m"
          limits:
            memory: "512Mi"
            cpu: "500m"
        livenessProbe:
          httpGet:
            path: /health
            port: 3000
          initialDelaySeconds: 30
          periodSeconds: 10
        readinessProbe:
          httpGet:
            path: /ready
            port: 3000
          initialDelaySeconds: 5
          periodSeconds: 5
---
apiVersion: v1
kind: Service
metadata:
  name: myapp-falcon-service
spec:
  selector:
    app: myapp-falcon
  ports:
  - port: 80
    targetPort: 3000
  type: ClusterIP

# 1. True thread-local storage - shared by every fiber in the worker
grep -rn "thread_variable_set\|thread_variable_get" app lib config

# 2. Fiber-local storage - fine for request state, dead as a cache
grep -rn "Thread\.current\[" app lib config

# 3. Gems with native extensions - the code the greps above cannot see
bundle exec ruby -e 'Gem::Specification.select { |s| s.extensions.any? }.each { |s| puts s.name }'

# Gemfile
gem "puma"    # unchanged - this is your rollback
gem "falcon"

#!/usr/bin/env falcon-host
# falcon.rb
require "falcon/environment/rack"

hostname = File.basename(__dir__)

service hostname do
	include Falcon::Environment::Rack

	# Load the app before forking, the way Puma's preload_app! does -
	# leave it out and your RSS-per-worker comparison measures the
	# missing preload rather than the server.
	preload "config/environment"

	port {ENV.fetch("PORT", 3000).to_i}

	endpoint do
		# HTTP/1.1 because a proxy in front of this app terminates TLS
		Async::HTTP::Endpoint
			.parse("http://0.0.0.0:#{port}")
			.with(protocol: Async::HTTP::Protocol::HTTP11)
	end
end

# app/controllers/api/aggregation_controller.rb
class Api::AggregationController < ApplicationController
  # This endpoint makes multiple API calls
  def dashboard_data
    # Start multiple concurrent requests
    user_future = Async { fetch_user_data(params[:user_id]) }
    stats_future = Async { fetch_analytics_data(params[:user_id]) }
    notifications_future = Async { fetch_notifications(params[:user_id]) }

    # Wait for all to complete
    user_data = user_future.wait
    stats_data = stats_future.wait
    notifications = notifications_future.wait

    render json: {
      user: user_data,
      stats: stats_data,
      notifications: notifications
    }
  end

  private

  def fetch_user_data(user_id)
    # Simulates external API call
    response = HTTP.timeout(5).get("https://api.userservice.com/users/#{user_id}")
    JSON.parse(response.body)
  end

  def fetch_analytics_data(user_id)
    response = HTTP.timeout(5).get("https://api.analytics.com/users/#{user_id}/stats")
    JSON.parse(response.body)
  end

  def fetch_notifications(user_id)
    response = HTTP.timeout(5).get("https://api.notifications.com/users/#{user_id}")
    JSON.parse(response.body)
  end
end

# app/channels/chat_channel.rb
class ChatChannel < ApplicationCable::Channel
  def subscribed
    stream_from "chat_room_#{params[:room_id]}"

    # Track connection count efficiently
    Redis.current.incr("chat_room_#{params[:room_id]}:connections")

    broadcast_user_joined
  end

  def unsubscribed
    Redis.current.decr("chat_room_#{params[:room_id]}:connections")
    broadcast_user_left
  end

  def speak(data)
    message = {
      user: current_user.name,
      message: data['message'],
      timestamp: Time.now.iso8601
    }

    # Store in database asynchronously
    Async { ChatMessage.create!(message.merge(room_id: params[:room_id])) }

    # Broadcast immediately
    ActionCable.server.broadcast("chat_room_#{params[:room_id]}", message)
  end

  private

  def broadcast_user_joined
    ActionCable.server.broadcast("chat_room_#{params[:room_id]}", {
      type: 'user_joined',
      user: current_user.name,
      connections: Redis.current.get("chat_room_#{params[:room_id]}:connections").to_i
    })
  end

  def broadcast_user_left
    ActionCable.server.broadcast("chat_room_#{params[:room_id]}", {
      type: 'user_left',
      user: current_user.name,
      connections: Redis.current.get("chat_room_#{params[:room_id]}:connections").to_i
    })
  end
end

# app/services/order_processing_service.rb
class OrderProcessingService
  include Async

  def process_order(order_id)
    order = Order.find(order_id)

    # Process multiple services concurrently
    Async do |task|
      # Start all operations concurrently
      inventory_task = task.async { reserve_inventory(order) }
      payment_task = task.async { process_payment(order) }
      shipping_task = task.async { calculate_shipping(order) }

      # Wait for critical operations
      inventory_result = inventory_task.wait
      payment_result = payment_task.wait

      if inventory_result[:success] && payment_result[:success]
        # Continue with non-critical operations
        shipping_result = shipping_task.wait

        # Trigger async notifications
        task.async { send_confirmation_email(order) }
        task.async { update_analytics(order) }
        task.async { sync_with_warehouse(order) }

        order.update!(
          status: 'confirmed',
          tracking_number: shipping_result[:tracking_number]
        )

        { success: true, order: order }
      else
        # Handle failures
        cleanup_failed_order(order, inventory_result, payment_result)
        { success: false, errors: [inventory_result, payment_result] }
      end
    end
  end

  private

  def reserve_inventory(order)
    # Call inventory service
    response = HTTP.timeout(10).post(
      "#{INVENTORY_SERVICE_URL}/reserve",
      json: { order_id: order.id, items: order.items.as_json }
    )

    JSON.parse(response.body).symbolize_keys
  rescue => e
    { success: false, error: e.message }
  end

  def process_payment(order)
    response = HTTP.timeout(15).post(
      "#{PAYMENT_SERVICE_URL}/charge",
      json: {
        amount: order.total,
        currency: order.currency,
        customer_id: order.customer_id
      }
    )

    JSON.parse(response.body).symbolize_keys
  rescue => e
    { success: false, error: e.message }
  end

  def calculate_shipping(order)
    response = HTTP.timeout(5).post(
      "#{SHIPPING_SERVICE_URL}/calculate",
      json: { order: order.as_json }
    )

    JSON.parse(response.body).symbolize_keys
  rescue => e
    { success: false, error: e.message }
  end
end

# app/controllers/uploads_controller.rb
class UploadsController < ApplicationController
  def create
    upload = Upload.create!(
      filename: params[:file].original_filename,
      content_type: params[:file].content_type,
      size: params[:file].size,
      status: 'processing'
    )

    # Stream file to storage asynchronously
    Async do
      begin
        # Upload to cloud storage
        storage_url = upload_to_storage(params[:file], upload.id)

        # Process file in background (start multiple processors)
        Async { generate_thumbnails(storage_url, upload) }
        Async { extract_metadata(storage_url, upload) }
        Async { scan_for_viruses(storage_url, upload) }

        upload.update!(
          storage_url: storage_url,
          status: 'uploaded'
        )

        # Notify completion via WebSocket
        ActionCable.server.broadcast(
          "uploads_#{current_user.id}",
          { type: 'upload_complete', upload: upload.as_json }
        )

      rescue => e
        upload.update!(status: 'failed', error: e.message)

        ActionCable.server.broadcast(
          "uploads_#{current_user.id}",
          { type: 'upload_failed', upload: upload.as_json, error: e.message }
        )
      end
    end

    render json: { upload: upload.as_json }, status: :accepted
  end

  private

  def upload_to_storage(file, upload_id)
    # Stream upload to S3/GCS
    key = "uploads/#{upload_id}/#{file.original_filename}"

    # Use async HTTP client for upload
    response = HTTP.timeout(300).put(
      "#{STORAGE_SERVICE_URL}/#{key}",
      body: file.read
    )

    response.headers['Location']
  end

  def generate_thumbnails(storage_url, upload)
    response = HTTP.timeout(60).post(
      "#{IMAGE_PROCESSING_URL}/thumbnails",
      json: { source_url: storage_url, upload_id: upload.id }
    )

    thumbnails = JSON.parse(response.body)
    upload.update!(thumbnails: thumbnails)
  end

  def extract_metadata(storage_url, upload)
    response = HTTP.timeout(30).post(
      "#{METADATA_SERVICE_URL}/extract",
      json: { source_url: storage_url }
    )

    metadata = JSON.parse(response.body)
    upload.update!(metadata: metadata)
  end
end

# Monitor fiber count and memory usage
class MemoryMonitor
  def self.report
    fiber_count = ObjectSpace.each_object(Fiber).count
    memory_usage = `ps -o rss= -p #{Process.pid}`.to_i * 1024

    Rails.logger.info(
      "MEMORY: #{memory_usage / 1024 / 1024}MB, " \
      "FIBERS: #{fiber_count}, " \
      "GC: #{GC.stat[:heap_live_slots]} live objects"
    )
  end
end

# Add to config/application.rb for periodic reporting
config.after_initialize do
  Thread.new do
    loop do
      sleep 60
      MemoryMonitor.report
    end
  end
end

# config/database.yml
production:
  pool: <%= ENV.fetch("DATABASE_POOL_SIZE", 25) %>
  checkout_timeout: 5

  # Add connection pool monitoring
  after_connect: |
    ActiveRecord::Base.logger.info(
      "DB Connection established: " \
      "#{ActiveRecord::Base.connection_pool.stat}"
    )

# Identify blocking operations
module BlockingDetector
  def self.wrap_method(klass, method_name)
    klass.alias_method :"#{method_name}_without_detector", method_name

    klass.define_method method_name do |*args, &block|
      start_time = Time.now
      result = send(:"#{method_name}_without_detector", *args, &block)
      duration = Time.now - start_time

      if duration > 0.1  # More than 100ms
        Rails.logger.warn(
          "BLOCKING: #{klass}##{method_name} took #{duration}s"
        )
      end

      result
    end
  end
end

# Wrap potentially blocking methods
BlockingDetector.wrap_method(Net::HTTP, :request)
BlockingDetector.wrap_method(File, :read)

# app/controllers/health_controller.rb
class HealthController < ApplicationController
  def check
    health_status = {
      status: 'ok',
      timestamp: Time.now.iso8601,
      version: Rails.application.config.version,
      checks: {}
    }

    # Database connectivity
    begin
      ActiveRecord::Base.connection.execute('SELECT 1')
      health_status[:checks][:database] = { status: 'ok' }
    rescue => e
      health_status[:checks][:database] = {
        status: 'error',
        message: e.message
      }
      health_status[:status] = 'error'
    end

    # Redis connectivity
    begin
      Redis.current.ping
      health_status[:checks][:redis] = { status: 'ok' }
    rescue => e
      health_status[:checks][:redis] = {
        status: 'error',
        message: e.message
      }
      health_status[:status] = 'error'
    end

    # Memory usage
    memory_mb = `ps -o rss= -p #{Process.pid}`.to_i / 1024
    health_status[:checks][:memory] = {
      status: memory_mb < 1024 ? 'ok' : 'warning',
      usage_mb: memory_mb
    }

    # Fiber count
    fiber_count = ObjectSpace.each_object(Fiber).count
    health_status[:checks][:fibers] = {
      status: fiber_count < 1000 ? 'ok' : 'warning',
      count: fiber_count
    }

    status_code = health_status[:status] == 'ok' ? 200 : 503
    render json: health_status, status: status_code
  end

  def ready
    # Readiness check for Kubernetes
    render json: { status: 'ready' }, status: 200
  end
end

# Gemfile
gem 'prometheus-client'

# config/initializers/prometheus.rb
require 'prometheus/client'

PROMETHEUS = Prometheus::Client.registry

# Define metrics
HTTP_REQUESTS = PROMETHEUS.counter(
  :http_requests_total,
  docstring: 'Total HTTP requests',
  labels: [:method, :path, :status]
)

HTTP_DURATION = PROMETHEUS.histogram(
  :http_request_duration_seconds,
  docstring: 'HTTP request duration',
  labels: [:method, :path]
)

FIBER_COUNT = PROMETHEUS.gauge(
  :falcon_fiber_count,
  docstring: 'Number of active fibers'
)

# Middleware for metrics collection
class PrometheusMiddleware
  def initialize(app)
    @app = app
  end

  def call(env)
    start_time = Time.now

    status, headers, response = @app.call(env)

    duration = Time.now - start_time
    method = env['REQUEST_METHOD']
    path = env['PATH_INFO']

    # Record metrics
    HTTP_REQUESTS.increment(
      labels: { method: method, path: path, status: status }
    )

    HTTP_DURATION.observe(
      duration,
      labels: { method: method, path: path }
    )

    # Update fiber count
    fiber_count = ObjectSpace.each_object(Fiber).count
    FIBER_COUNT.set(fiber_count)

    [status, headers, response]
  end
end

# Add middleware
Rails.application.config.middleware.use PrometheusMiddleware

# Request rate
rate(http_requests_total[5m])

# Response time 95th percentile
histogram_quantile(0.95, rate(http_request_duration_seconds_bucket[5m]))

# Fiber count over time
falcon_fiber_count

# Error rate
rate(http_requests_total{status=~"5.."}[5m]) / rate(http_requests_total[5m])

# Memory usage
process_resident_memory_bytes / 1024 / 1024

# Enable fiber tracing
class FiberTracer
  def self.enable!
    TracePoint.trace(:fiber_switch) do |tp|
      Rails.logger.debug(
        "FIBER: Switch from #{tp.from_fiber} to #{tp.to_fiber}"
      )
    end
  end
end

# Enable in development
FiberTracer.enable! if Rails.env.development?

# Wrap async operations with logging
module AsyncDebugger
  def self.wrap_async(&block)
    fiber_id = Fiber.current.object_id
    start_time = Time.now

    Rails.logger.debug("ASYNC: Starting operation in fiber #{fiber_id}")

    result = yield

    duration = Time.now - start_time
    Rails.logger.debug(
      "ASYNC: Completed operation in fiber #{fiber_id} " \
      "(#{duration.round(3)}s)"
    )

    result
  end
end

# Usage
def expensive_operation
  AsyncDebugger.wrap_async do
    # Your async code here
    external_api_call
  end
end

# Current Ruby 3.x
Fiber.schedule do
  # Non-blocking I/O operations
  Net::HTTP.get(uri)
end

# Planned Ruby improvements
# Better integration with standard library
# Automatic fiber scheduling for common operations
# Improved debugging and profiling tools

# Future possibility: Falcon + Ractors
def process_heavy_computation(data)
  ractor = Ractor.new(data) do |input|
    # CPU-intensive work in separate ractor
    complex_calculation(input)
  end

  # Continue with other fibers while ractor works
  ractor.take  # Non-blocking in fiber context
end

# async-postgres example
require 'async/postgres'

Async do
  client = Async::Postgres::Client.new(
    host: 'localhost',
    database: 'myapp'
  )

  # Non-blocking query
  result = client.query("SELECT * FROM users WHERE active = $1", true)
  result.each do |row|
    puts row['name']
  end

  client.close
end

# async-http client
require 'async/http/internet'

Async do |task|
  internet = Async::HTTP::Internet.new

  # Multiple concurrent requests
  responses = task.async do
    [
      internet.get("https://api1.example.com/data"),
      internet.get("https://api2.example.com/data"),
      internet.get("https://api3.example.com/data")
    ]
  end.map(&:wait)

  responses.each { |response| puts response.read }
ensure
  internet&.close
end

# Rails 7+ async queries
User.where(active: true).load_async
Post.includes(:comments).load_async

# Future: More async integrations
# - Async job processing
# - Async middleware
# - Async template rendering

# Example async-first framework
require 'async_web'

class MyAsyncApp < AsyncWeb::Application
  get '/users/:id' do |params|
    # Everything is async by default
    user = User.find_async(params[:id])
    posts = Post.where(user_id: params[:id]).load_async

    render json: {
      user: user.await,
      posts: posts.await
    }
  end

  websocket '/chat' do |ws|
    # Built-in WebSocket support
    ws.on_message do |message|
      broadcast_to_room(ws.room, message)
    end
  end
end

# Enable YJIT for Falcon
RUBY_YJIT_ENABLE=1 falcon serve

# Expected improvements:
# - 15-30% faster request processing
# - Better memory efficiency
# - Faster fiber switching

# Potential future: Native fiber scheduling
# Better HTTP/2 performance
# Optimized WebSocket handling
# SIMD-accelerated JSON parsing

# Resource management pattern
class AsyncResourceManager
  def initialize
    @semaphore = Async::Semaphore.new(10)  # Limit concurrent operations
  end

  def process_safely(&block)
    @semaphore.async do
      begin
        yield
      rescue => e
        # Proper error handling in async context
        Rails.logger.error("Async operation failed: #{e.message}")
        raise
      end
    end
  end
end

# Usage
manager = AsyncResourceManager.new

Async do |task|
  results = 100.times.map do |i|
    manager.process_safely do
      expensive_api_call(i)
    end
  end

  # Wait for all to complete
  results.map(&:wait)
end

# RSpec async testing
require 'async/rspec'

RSpec.describe MyAsyncService, async: true do
  it "processes requests concurrently" do |task|
    service = MyAsyncService.new

    # Start multiple operations
    operations = 5.times.map do |i|
      task.async { service.process_item(i) }
    end

    # Verify they complete in reasonable time
    start_time = Time.now
    results = operations.map(&:wait)
    duration = Time.now - start_time

    expect(results.length).to eq(5)
    expect(duration).to be < 2.0  # Should complete concurrently
  end
end