nr: #1 dodano: 2016-10-14 01:10
After some digging into source code here is what I found out:
ActiveJob::QueueAdapters::AsyncAdapter uses a Concurrent Ruby thread pool to schedule and execute jobs.
When you initialize the adapter in your configuration, you pass executor options, which in turn happen to be arguments to
initialize method of
Created instance of
Concurrent::ThreadPoolExecutor class has such methods, as:
queue_length - The number of tasks in the queue awaiting execution.
scheduled_task_count - The number of tasks that have been scheduled for execution on the pool since construction.
That said, I think something along these lines should do it for you:
Above does the following:
- get your adapter
- get its instance_variable
@scheduler, that points to
- instance of
Concurrent::ThreadPoolExecutor (instance variable of
Scheduler class -
- on which you can actually call the methods, described above (
scheduled_task_count and others)
Though I did not tested it, so make sure to double check for typos or whatsoever.