module Concurrent::Async::ClassMethods

def new(*args, &block)
  obj = original_new(*args, &block)
  obj.send(:init_synchronization)
  obj
end