Gecko [ tsuru-no-tsurugi.tokyo ]

Name	Size	Permission	Date
cli	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
compact_index_client	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
fetcher	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
installer	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
man	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
plugin	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
resolver	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
settings	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
source	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
templates	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
ui	[ DIR ]	drwxr-xr-x	2026-07-06 06:50
vendor	[ DIR ]	drwxr-xr-x	2026-02-06 13:11
build_metadata.rb	1.22 KB	-rw-r--r--	2021-07-07 19:08
capistrano.rb	883 B	-rw-r--r--	2021-07-07 19:08
cli.rb	38.09 KB	-rw-r--r--	2021-07-07 19:08
compact_index_client.rb	3.59 KB	-rw-r--r--	2021-07-07 19:08
constants.rb	212 B	-rw-r--r--	2021-07-07 19:08
current_ruby.rb	2.14 KB	-rw-r--r--	2021-07-07 19:08
definition.rb	32.47 KB	-rw-r--r--	2021-07-07 19:08
dep_proxy.rb	961 B	-rw-r--r--	2021-07-07 19:08
dependency.rb	4.79 KB	-rw-r--r--	2021-07-07 19:08
deployment.rb	3.19 KB	-rw-r--r--	2021-07-07 19:08
deprecate.rb	876 B	-rw-r--r--	2021-07-07 19:08
dsl.rb	19.9 KB	-rw-r--r--	2021-07-07 19:08
endpoint_specification.rb	3.91 KB	-rw-r--r--	2021-07-07 19:08
env.rb	5.01 KB	-rw-r--r--	2021-07-07 19:08
environment_preserver.rb	1.9 KB	-rw-r--r--	2021-07-07 19:08
errors.rb	4.67 KB	-rw-r--r--	2021-07-07 19:08
feature_flag.rb	1.94 KB	-rw-r--r--	2021-07-07 19:08
fetcher.rb	11.22 KB	-rw-r--r--	2021-07-07 19:08
friendly_errors.rb	4.34 KB	-rw-r--r--	2021-07-07 19:08
gem_helper.rb	7.38 KB	-rw-r--r--	2021-07-07 19:08
gem_helpers.rb	3.85 KB	-rw-r--r--	2021-07-07 19:08
gem_tasks.rb	138 B	-rw-r--r--	2021-07-07 19:08
gem_version_promoter.rb	6.54 KB	-rw-r--r--	2021-07-07 19:08
gemdeps.rb	423 B	-rw-r--r--	2021-07-07 19:08
graph.rb	4.99 KB	-rw-r--r--	2021-07-07 19:08
index.rb	5.38 KB	-rw-r--r--	2021-07-07 19:08
injector.rb	9.46 KB	-rw-r--r--	2021-07-07 19:08
inline.rb	2.79 KB	-rw-r--r--	2021-07-07 19:08
installer.rb	11.37 KB	-rw-r--r--	2021-07-07 19:08
lazy_specification.rb	4.13 KB	-rw-r--r--	2021-07-07 19:08
lockfile_generator.rb	2.18 KB	-rw-r--r--	2021-07-07 19:08
lockfile_parser.rb	7.21 KB	-rw-r--r--	2021-07-07 19:08
match_platform.rb	660 B	-rw-r--r--	2021-07-07 19:08
mirror.rb	5.82 KB	-rw-r--r--	2021-07-07 19:08
plugin.rb	10.58 KB	-rw-r--r--	2021-07-07 19:08
process_lock.rb	702 B	-rw-r--r--	2021-07-07 19:08
psyched_yaml.rb	582 B	-rw-r--r--	2021-07-07 19:08
remote_specification.rb	3.64 KB	-rw-r--r--	2021-07-07 19:08
resolver.rb	15.15 KB	-rw-r--r--	2021-07-07 19:08
retry.rb	1.61 KB	-rw-r--r--	2021-07-07 19:08
ruby_dsl.rb	761 B	-rw-r--r--	2021-07-07 19:08
ruby_version.rb	4.45 KB	-rw-r--r--	2021-07-07 19:08
rubygems_ext.rb	5.93 KB	-rw-r--r--	2021-07-07 19:08
rubygems_gem_installer.rb	4.38 KB	-rw-r--r--	2021-07-07 19:08
rubygems_integration.rb	17.28 KB	-rw-r--r--	2021-07-07 19:08
runtime.rb	10.36 KB	-rw-r--r--	2021-07-07 19:08
settings.rb	12.92 KB	-rw-r--r--	2021-07-07 19:08
setup.rb	802 B	-rw-r--r--	2021-07-07 19:08
shared_helpers.rb	11.27 KB	-rw-r--r--	2021-07-07 19:08
similarity_detector.rb	1.84 KB	-rw-r--r--	2021-07-07 19:08
source.rb	3.08 KB	-rw-r--r--	2021-07-07 19:08
source_list.rb	6.68 KB	-rw-r--r--	2021-07-07 19:08
source_map.rb	1.78 KB	-rw-r--r--	2021-07-07 19:08
spec_set.rb	5.42 KB	-rw-r--r--	2021-07-07 19:08
stub_specification.rb	2.87 KB	-rw-r--r--	2021-07-07 19:08
ui.rb	255 B	-rw-r--r--	2021-07-07 19:08
uri_credentials_filter.rb	1.28 KB	-rw-r--r--	2021-07-07 19:08
vendored_fileutils.rb	101 B	-rw-r--r--	2021-07-07 19:08
vendored_molinillo.rb	101 B	-rw-r--r--	2021-07-07 19:08
vendored_persistent.rb	1.44 KB	-rw-r--r--	2021-07-07 19:08
vendored_thor.rb	180 B	-rw-r--r--	2021-07-07 19:08
vendored_tmpdir.rb	95 B	-rw-r--r--	2021-07-07 19:08
vendored_uri.rb	89 B	-rw-r--r--	2021-07-07 19:08
version.rb	180 B	-rw-r--r--	2021-07-07 19:08
version_ranges.rb	3.8 KB	-rw-r--r--	2021-07-07 19:08
vlad.rb	468 B	-rw-r--r--	2021-07-07 19:08
worker.rb	2.59 KB	-rw-r--r--	2021-07-07 19:08
yaml_serializer.rb	2.36 KB	-rw-r--r--	2021-07-07 19:08

Rename

# frozen_string_literal: true

module Bundler
  class Worker
    POISON = Object.new

class WrappedException < StandardError
      attr_reader :exception
      def initialize(exn)
        @exception = exn
      end
    end

# @return [String] the name of the worker
    attr_reader :name

# Creates a worker pool of specified size
    #
    # @param size [Integer] Size of pool
    # @param name [String] name the name of the worker
    # @param func [Proc] job to run in inside the worker pool
    def initialize(size, name, func)
      @name = name
      @request_queue = Queue.new
      @response_queue = Queue.new
      @func = func
      @size = size
      @threads = nil
      SharedHelpers.trap("INT") { abort_threads }
    end

# Enqueue a request to be executed in the worker pool
    #
    # @param obj [String] mostly it is name of spec that should be downloaded
    def enq(obj)
      create_threads unless @threads
      @request_queue.enq obj
    end

# Retrieves results of job function being executed in worker pool
    def deq
      result = @response_queue.deq
      raise result.exception if result.is_a?(WrappedException)
      result
    end

def stop
      stop_threads
    end

private

def process_queue(i)
      loop do
        obj = @request_queue.deq
        break if obj.equal? POISON
        @response_queue.enq apply_func(obj, i)
      end
    end

def apply_func(obj, i)
      @func.call(obj, i)
    rescue Exception => e # rubocop:disable Lint/RescueException
      WrappedException.new(e)
    end

# Stop the worker threads by sending a poison object down the request queue
    # so as worker threads after retrieving it, shut themselves down
    def stop_threads
      return unless @threads
      @threads.each { @request_queue.enq POISON }
      @threads.each(&:join)
      @threads = nil
    end

def abort_threads
      return unless @threads
      Bundler.ui.debug("\n#{caller.join("\n")}")
      @threads.each(&:exit)
      exit 1
    end

def create_threads
      creation_errors = []

@threads = Array.new(@size) do |i|
        begin
          Thread.start { process_queue(i) }.tap do |thread|
            thread.name = "#{name} Worker ##{i}" if thread.respond_to?(:name=)
          end
        rescue ThreadError => e
          creation_errors << e
          nil
        end
      end.compact

return if creation_errors.empty?

message = "Failed to create threads for the #{name} worker: #{creation_errors.map(&:to_s).uniq.join(", ")}"
      raise ThreadCreationError, message if @threads.empty?
      Bundler.ui.info message
    end
  end
end