?HAMA

Navigation

Breadcrumbs

/ / proc / thread-self / root / opt / alt / ruby32 / share / gems / gems / bundler-2.4.19 / lib / bundler

Create

Create File | Create Folder | Upload Files | Run Command

Edit File Size: 2.85 KB

/proc/thread-self/root/opt/alt/ruby32/share/gems/gems/bundler-2.4.19/lib/bundler/worker.rb

Text Base64

# 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 = Thread::Queue.new
      @response_queue = Thread::Queue.new
      @func = func
      @size = size
      @threads = nil
      @previous_interrupt_handler = nil
    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)

remove_interrupt_handler

@threads = nil
    end

def abort_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|
        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.compact

add_interrupt_handler unless @threads.empty?

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

def add_interrupt_handler
      @previous_interrupt_handler = trap("INT") { abort_threads }
    end

def remove_interrupt_handler
      return unless @previous_interrupt_handler

trap "INT", @previous_interrupt_handler
    end
  end
end

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 12 × Files: 71

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
cli DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
compact_index_client DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
fetcher DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
installer DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
man DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
plugin DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
resolver DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
settings DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
source DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
templates DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
ui DIR	-	drwxr-xr-x	2026-04-30 07:09:26	Edit Download recursive recursive
vendor DIR	-	drwxr-xr-x	2026-04-07 14:12:46	Edit Download recursive recursive
build_metadata.rb	1.20 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
capistrano.rb	883 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
cli.rb	41.00 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
compact_index_client.rb	3.36 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
constants.rb	224 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
current_ruby.rb	2.43 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
definition.rb	32.33 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
dependency.rb	3.11 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
deployment.rb	3.19 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
deprecate.rb	876 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
digest.rb	2.16 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
dsl.rb	19.97 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
endpoint_specification.rb	3.65 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
env.rb	5.01 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
environment_preserver.rb	1.94 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
errors.rb	5.17 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
feature_flag.rb	1.79 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
fetcher.rb	11.19 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
force_platform.rb	557 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
friendly_errors.rb	3.75 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
gem_helper.rb	6.89 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
gem_helpers.rb	4.08 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
gem_tasks.rb	138 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
gem_version_promoter.rb	4.76 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
graph.rb	4.99 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
index.rb	4.14 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
injector.rb	10.08 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
inline.rb	2.47 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
installer.rb	10.25 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
lazy_specification.rb	5.35 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
lockfile_generator.rb	2.18 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
lockfile_parser.rb	7.01 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
match_metadata.rb	290 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
match_platform.rb	583 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
match_remote_metadata.rb	863 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
mirror.rb	5.78 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
plugin.rb	11.25 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
process_lock.rb	686 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
remote_specification.rb	3.71 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
resolver.rb	14.62 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
retry.rb	1.61 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
rubygems_ext.rb	10.88 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
rubygems_gem_installer.rb	5.24 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
rubygems_integration.rb	15.82 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
ruby_dsl.rb	961 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
ruby_version.rb	4.17 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
runtime.rb	10.15 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
safe_marshal.rb	597 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
self_manager.rb	4.76 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
settings.rb	13.19 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
setup.rb	963 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
shared_helpers.rb	10.76 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
similarity_detector.rb	1.84 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
source.rb	2.98 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
source_list.rb	6.18 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
source_map.rb	2.17 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
spec_set.rb	5.08 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
stub_specification.rb	2.79 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
ui.rb	255 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
uri_credentials_filter.rb	1.28 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
uri_normalizer.rb	715 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
vendored_fileutils.rb	101 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
vendored_persistent.rb	270 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
vendored_pub_grub.rb	99 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
vendored_thor.rb	180 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
vendored_tsort.rb	93 B	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
vendored_uri.rb	89 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
version.rb	260 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
vlad.rb	468 B	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive
worker.rb	2.85 KB	lrw-r--r--	2026-04-07 14:12:50	Edit Download recursive recursive
yaml_serializer.rb	2.36 KB	lrw-r--r--	2026-04-07 14:12:49	Edit Download recursive recursive