1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
#!/usr/bin/env ruby
# frozen_string_literal: true
# Released under the MIT License.
# Copyright, 2021-2022, by Samuel Williams.
require 'async'
require 'async/pool/controller'
require 'async/pool/resource'
class MyResource < Async::Pool::Resource
def self.call
Async::Task.current.sleep(1)
self.new
end
end
Async do
progress = Console.logger.progress("Pool Usage", 10*10)
pool = Async::Pool::Controller.new(MyResource, concurrency: 10)
10.times do
Async do
10.times do
resource = pool.acquire
pool.release(resource)
progress.increment
end
end
end
end
|
