Class: Contrast::Agent::WorkerThread

Inherits:

Object

• Object
• Contrast::Agent::WorkerThread

Includes:

Components::Logger::InstanceMethods

Defined in:

lib/contrast/agent/thread/worker_thread.rb

Overview

Base class for threads that do async processing

Direct Known Subclasses

Protect::WorthWatchingInputAnalyzer, Reporter, ReportingWorkers::ApplicationServerWorker, ReportingWorkers::ReporterHeartbeat, ReportingWorkers::ServerSettingsWorker, Telemetry::Base, Utils::HeapDumpUtil

Instance Method Summary

• #attempt_to_start? ⇒ Boolean

  Most threads, we always want to start.

• #clean_properties ⇒ Object
• #initialize ⇒ WorkerThread constructor

  A new instance of WorkerThread.

• #running? ⇒ Boolean
• #stop! ⇒ Object

Methods included from Components::Logger::InstanceMethods

#cef_logger, #logger

Constructor Details

#initialize ⇒ WorkerThread

# File 'lib/contrast/agent/thread/worker_thread.rb', line 12

def initialize
  @_thread = nil
end

Instance Method Details

#attempt_to_start? ⇒ Boolean

Most threads, we always want to start. Some may be controlled by feature guards though, so we need to check.

# File 'lib/contrast/agent/thread/worker_thread.rb', line 31

def attempt_to_start?
  Contrast::AGENT.enabled?
end

#clean_properties ⇒ Object

# File 'lib/contrast/agent/thread/worker_thread.rb', line 35

def clean_properties
  logger.debug("Cleaning PROPERTIES_HASH size: #{ Contrast::Agent::Assess::Tracker::PROPERTIES_HASH.size }")
  Contrast::Agent::Assess::Tracker.cleanup!
  logger.debug("Cleaned PROPERTIES_HASH size: #{ Contrast::Agent::Assess::Tracker::PROPERTIES_HASH.size }")
end

#running? ⇒ Boolean

# File 'lib/contrast/agent/thread/worker_thread.rb', line 16

def running?
  !!@_thread&.alive?
end

#stop! ⇒ Object

# File 'lib/contrast/agent/thread/worker_thread.rb', line 20

def stop!
  return unless running?
  return unless @_thread

  Thread.kill(@_thread)
  @_thread = nil
end