Skip to content

Commit 32db33c

Browse files
committed
Increase number of jobs.
1 parent 74cc92b commit 32db33c

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

examples/queue/server.rb

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ def initialize
3535

3636
container.spawn do |instance|
3737
Async do
38-
queue = 8.times.to_a
38+
queue = 500_000.times.to_a
3939
Console.logger.info(self) {"Hosting the queue..."}
4040

4141
instance.ready!
@@ -59,7 +59,7 @@ def initialize
5959
break
6060
end
6161
when :status
62-
Console.logger.info("Job Status") {arguments}
62+
# Console.logger.info("Job Status") {arguments}
6363
else
6464
Console.logger.warn(self) {"Unhandled command: #{command}#{arguments.inspect}"}
6565
end
@@ -84,7 +84,7 @@ def initialize
8484

8585
case command
8686
when :job
87-
task.sleep(*arguments)
87+
# task.sleep(*arguments)
8888
packer.write([:status, *arguments])
8989
packer.write([:ready])
9090
packer.flush
@@ -97,3 +97,5 @@ def initialize
9797
end
9898

9999
container.wait
100+
101+
Console.logger.info(self) {"Done!"}

0 commit comments

Comments
 (0)