แสดงรายการงานที่เข้าคิวด้วย ActiveJob AsyncAdapter

หลังจากเจาะลึกเข้าไปใน ซอร์สโค้ด นี่คือสิ่งที่ฉันพบ:

ActiveJob::QueueAdapters::AsyncAdapter ใช้ Concurrent Ruby เธรดพูลเพื่อกำหนดเวลาและดำเนินงาน

เมื่อคุณเริ่มต้นอะแดปเตอร์ในการกำหนดค่าของคุณ คุณจะต้องส่ง ตัวเลือกตัวดำเนินการ ซึ่งจะกลายเป็นอาร์กิวเมนต์ไปยังเมธอด initialize ของ Concurrent::ThreadPoolExecutor คลาส

อินสแตนซ์ที่สร้างขึ้นของคลาส Concurrent::ThreadPoolExecutor มีวิธีการดังกล่าว เช่น:

• queue_length - จำนวนงานใน คิวที่รอการดำเนินการ
• scheduled_task_count - จำนวนงานที่มี มีกำหนดประหารชีวิตบนสระน้ำตั้งแต่การก่อสร้าง

ที่กล่าวว่าฉันคิดว่าบางสิ่งบางอย่างในบรรทัดเหล่านี้ควรทำเพื่อคุณ:

ActiveJob::Base
  .queue_adapter
  .instance_variable_get(:@scheduler)
  .instance_variable_get(:@async_executor)
  .public_send(:queue_length)

ข้างต้นทำสิ่งต่อไปนี้:

1. รับอะแดปเตอร์ของคุณ
2. รับ instance_variable @scheduler นั่นชี้ไปที่
3. อินสแตนซ์ของ Concurrent::ThreadPoolExecutor (ตัวแปรอินสแตนซ์ของคลาส Scheduler - @async_executor)
4. ซึ่งคุณสามารถเรียกใช้วิธีการตามที่อธิบายไว้ข้างต้น (queue_length, scheduled_task_count และ อื่นๆ)

แม้ว่าฉันจะไม่ได้ทดสอบ ดังนั้นอย่าลืมตรวจสอบการพิมพ์ผิดหรืออะไรก็ตามอีกครั้ง