ubugnu
ubugnu

Reputation: 1082

Sidekiq async tasks are done synchronously

I have two Sidekiq workers:

# app/workers/client_worker.rb
class ClientWorker
  include Sidekiq::Worker

  def perform(*args)
    puts "client started\n"
  end
end

and

# app/workers/server_worker.rb
class ServerWorker
  include Sidekiq::Worker

  def perform(*args)
    i = 0
    loop do
      begin
        i = i + 1
        puts "server waiting"
        sleep(2)
        if i > 5
          break
        end
      rescue => e
      end
    end
  end
end

I have two Rails apps, same rails version, same ruby version, same gems versions.

rvm use [email protected]

On a fresh Rails App When I start server worker, then immediatly after, client worker, I get client message as expected amongst server messages:

2018-06-21T22:44:19.855Z 32364 TID-gn863tph0 ServerWorker JID-7cdd1fd3d6fe63c91d99f3b0 INFO: start
server waiting
server waiting
server waiting
2018-06-21T22:44:24.356Z 32364 TID-gn865q1zk ClientWorker JID-7dc887d6824d0b789afec69d INFO: start
client started
2018-06-21T22:44:24.357Z 32364 TID-gn865q1zk ClientWorker JID-7dc887d6824d0b789afec69d INFO: done: 0.001 sec
server waiting
server waiting
server waiting
2018-06-21T22:44:31.858Z 32364 TID-gn863tph0 ServerWorker JID-7cdd1fd3d6fe63c91d99f3b0 INFO: done: 12.003 sec

On an already developed Rails app

When I repeat this process, tasks are running one after the other:

2018-06-21T22:41:34.250Z 32247 TID-grdaosqf3 ServerWorker JID-5a2d9917e6575d6858644474 INFO: start
server waiting
server waiting
server waiting
2018-06-21T22:41:38.402Z 32247 TID-grdamch6b ClientWorker JID-5da83582991bf284f6357046 INFO: start
server waiting
server waiting
server waiting
client started
2018-06-21T22:41:46.259Z 32247 TID-grdaosqf3 ServerWorker JID-5a2d9917e6575d6858644474 INFO: done: 12.007 sec
2018-06-21T22:41:46.259Z 32247 TID-grdamch6b ClientWorker JID-5da83582991bf284f6357046 INFO: done: 7.858 sec

What I've tried

Now I'm running out of ideas! Can anyone suggest me a method to find out what's wrong?

EDIT Okey, after a long hesitation I decided to do the same change I made in new app in old app, namely: in new app I remarked that workers are not included automatically, so I added the following initializer:

# config/initializers/01_extensions.rb
Dir["#{Rails.root}/app/workers/*.rb"].each { |file| require file }

In old app, workers were included automatically (I really don't know which is the default behaviour!), so this initializer was not necessary.

BUT NOW when I decided to add the same initializer to old app, tasks are running async as expected.

Now I have two questions:

Upvotes: 0

Views: 1072

Answers (1)

Mike Perham
Mike Perham

Reputation: 22228

In development, Rails 5 effectively limits you to one job at a time, even with multiple threads. This global "executor" lock allows for the development reloading that Rails is famous for.

In production, jobs will be executed concurrently as you'd expect.

Upvotes: 2

Related Questions