dispatch v0.1.0
Dispatch
In-memory job queuing
# example.cr
require "./src/dispatch"
Dispatch.configure do |config|
config.num_workers = 5
config.queue_size = 10
config.logger = Logger.new(IO::Memory.new)
end
class FakeJob
include Dispatchable
def perform(name)
p "#{Time.now}: Hello, #{name}"
end
end
class ErrorJob
include Dispatchable
def perform
raise "Hello!"
end
end
Dispatch.config # => <Dispatch::Configuration:0x1042dafb0 @num_workers=5, @queue_size=10>
FakeJob.dispatch("Bob")
FakeJob.dispatch("Emily")
FakeJob.dispatch_in(5.seconds, "Billy")
FakeJob.dispatch("Maddy")
ErrorJob.dispatch
Dispatch.successes # => 0
sleep 6
Dispatch.successes # => 4
Dispatch.failures # => 1
Output:
"2016-12-13 14:23:53 -0500: Hello, Bob"
"2016-12-13 14:23:53 -0500: Hello, Emily"
"2016-12-13 14:23:53 -0500: Hello, Maddy"
"2016-12-13 14:23:58 -0500: Hello, Billy"
Repository
dispatch
Owner
Statistic
- 32
- 3
- 1
- 6
- 0
- 10 months ago
- November 29, 2016
License
Links
Synced at
Thu, 07 Nov 2024 00:27:49 GMT
Languages