diff options
author | Jeremy Daer <jeremydaer@gmail.com> | 2016-02-28 11:45:16 -0700 |
---|---|---|
committer | Jeremy Daer <jeremydaer@gmail.com> | 2016-02-29 15:58:26 -0700 |
commit | a66780bfff40ddaa1b2eed2f5f2e8b077558d761 (patch) | |
tree | a1add8bcd059ecb06b01ca78c15f00f024a3a0ec /activejob/test/cases | |
parent | b04d07337fd7bc17e88500e9d6bcd361885a45f8 (diff) | |
download | rails-a66780bfff40ddaa1b2eed2f5f2e8b077558d761.tar.gz rails-a66780bfff40ddaa1b2eed2f5f2e8b077558d761.tar.bz2 rails-a66780bfff40ddaa1b2eed2f5f2e8b077558d761.zip |
Active Job: smaller footprint for the dev/test async adapter
Use one shared worker pool for all queues with 0-#CPU workers rather
than separate pools per queue with 2-10*#CPU workers each.
Diffstat (limited to 'activejob/test/cases')
-rw-r--r-- | activejob/test/cases/async_job_test.rb | 42 |
1 files changed, 0 insertions, 42 deletions
diff --git a/activejob/test/cases/async_job_test.rb b/activejob/test/cases/async_job_test.rb deleted file mode 100644 index 2642cfc608..0000000000 --- a/activejob/test/cases/async_job_test.rb +++ /dev/null @@ -1,42 +0,0 @@ -require 'helper' -require 'jobs/hello_job' -require 'jobs/queue_as_job' - -class AsyncJobTest < ActiveSupport::TestCase - def using_async_adapter? - ActiveJob::Base.queue_adapter.is_a? ActiveJob::QueueAdapters::AsyncAdapter - end - - setup do - ActiveJob::AsyncJob.perform_asynchronously! - end - - teardown do - ActiveJob::AsyncJob::QUEUES.clear - ActiveJob::AsyncJob.perform_immediately! - end - - test "#create_thread_pool returns a thread_pool" do - thread_pool = ActiveJob::AsyncJob.create_thread_pool - assert thread_pool.is_a? Concurrent::ExecutorService - assert_not thread_pool.is_a? Concurrent::ImmediateExecutor - end - - test "#create_thread_pool returns an ImmediateExecutor after #perform_immediately! is called" do - ActiveJob::AsyncJob.perform_immediately! - thread_pool = ActiveJob::AsyncJob.create_thread_pool - assert thread_pool.is_a? Concurrent::ImmediateExecutor - end - - test "enqueuing without specifying a queue uses the default queue" do - skip unless using_async_adapter? - HelloJob.perform_later - assert ActiveJob::AsyncJob::QUEUES.key? 'default' - end - - test "enqueuing to a queue that does not exist creates the queue" do - skip unless using_async_adapter? - QueueAsJob.perform_later - assert ActiveJob::AsyncJob::QUEUES.key? QueueAsJob::MY_QUEUE.to_s - end -end |