wm: irc-h2o-bot

Info  •  Files  •  Log  •  Branches

Concurrent and new Test For That Added

--- a/Test_Multi_Threading.rb

+++ b/Test_Multi_Threading.rb

@@ -1,4 +1,24 @@

 require 'thread'

+require 'concurrent'

+

+executor = Concurrent::ThreadPoolExecutor.new(

+  min_threads: 2,

+  max_threads: 5,

+  max_queue: 10

+)

+

+futures = []

+

+5.times do |i|

+  futures << Concurrent::Future.execute(executor: executor) do

+    puts "Async task #{i} started"

+    sleep(rand(1..5))

+    puts "Async task #{i} finished"

+  end

+end

+

+futures.each(&:wait)

+executor.shutdown

 # Define a method that performs some asynchronous task

 def async_task(name)