bcardiff

# $ crystal run -Dpreview_mt synchronized.cr

struct Synchronized(T)
  @lock = Mutex.new

  getter inner : T

  def initialize(@inner : T)
  end

oprypin

module Indexable(T)
  def threadpool_map(workers : Int = 8, chunk_size : Int? = nil, &func : T -> R) forall T, R
    mutex = Thread::Mutex.new
    cs = chunk_size || (self.size**0.5).ceil.to_i
    Array(R).build(self.size) do |result|
      index = 0
      threads = Array.new(workers) {
        Thread.new do
          a = b = 0
          loop do