如何在Rails中检查Active Job是否以内联方式运行？

ActiveJob本身没有提供直接的内置方法区分perform_now（内联同步）和perform_later（异步后台）的执行方式，但有几种符合Rails风格的实现思路：

方案一：借助provider_job_id属性（简单直接） #

内联执行时，provider_job_id会保持nil；而通过后台队列执行的任务，这个属性会被赋值为队列服务生成的唯一ID。这是最直接的判断方式，多数场景下完全够用：

class MyJob < ActiveJob::Base
  def perform
    if provider_job_id.nil?
      # 内联执行（perform_now）的逻辑
    else
      # 异步执行（perform_later）的逻辑
    end
  end
end

方案二：自定义标记（更灵活可控） #

如果需要更明确的标记，或者要处理重试等复杂场景，可以通过自定义属性或上下文来标记执行方式：

覆写类方法标记执行类型 #

class MyJob < ActiveJob::Base
  attr_accessor :is_inline

  def self.perform_now(*args)
    job = new(*args)
    job.is_inline = true
    job.perform
  end

  def self.perform_later(*args)
    job = new(*args)
    job.is_inline = false
    super
  end

  def perform
    if is_inline
      # 内联执行逻辑
    else
      # 异步执行逻辑
    end
  end
end

利用job_context传递标记 #

Rails的set方法可以传递自定义上下文，调用时明确标记执行方式：

class MyJob < ActiveJob::Base
  def perform
    if job_context.dig(:execution_type) == :inline
      # 内联执行逻辑
    else
      # 异步执行逻辑
    end
  end
end

# 调用示例
MyJob.set(execution_type: :inline).perform_now
MyJob.set(execution_type: :async).perform_later

方案三：通过executions属性辅助判断 #

首次执行时，perform_now和perform_later的executions都是1，但如果任务被重试，异步任务的executions会递增。结合provider_job_id可以区分首次执行的来源：

class MyJob < ActiveJob::Base
  def perform
    if executions == 1 && provider_job_id.nil?
      # 首次内联执行
    elsif executions >= 1 && provider_job_id.present?
      # 异步执行（包括重试）
    end
  end
end

内容的提问来源于stack exchange，提问作者Tom Rossi