code: def __init__(
      self,
      paramSource,
      resultSinc,
      barFeed,
      address,
      port,
      autoStop=True,
      batchSize=200,
  ):
      assert batchSize > 0, "Invalid batch size"
  
      xmlrpc_server.SimpleXMLRPCServer.__init__(
          self,
          (address, port),
          requestHandler=RequestHandler,
          logRequests=False,
          allow_none=True,
      )
      # super(Server, self).__init__(
      # (address, port), requestHandler=RequestHandler, logRequests=False, allow_none=True
      # )
  
      self.__batchSize = batchSize
      self.__paramSource = paramSource
      self.__resultSinc = resultSinc
      self.__barFeed = barFeed
      self.__instrumentsAndBars = (
          None  # Serialized instruments and bars for faster retrieval.
      )
      self.__barsFreq = None
      self.__activeJobs = {}
      self.__lock = threading.Lock()
      self.__startedServingEvent = threading.Event()
      self.__forcedStop = False
      self.__bestResult = None
      if autoStop:
          self.__autoStopThread = AutoStopThread(self)
      else:
          self.__autoStopThread = None
  
      self.register_introspection_functions()
      self.register_function(
          self.getInstrumentsAndBars, "getInstrumentsAndBars"
      )
      self.register_function(self.getBarsFrequency, "getBarsFrequency")
      self.register_function(self.getNextJob, "getNextJob")
      self.register_function(self.pushJobResults, "pushJobResults")
  
imports: import threading
  import time
  from six.moves import xmlrpc_server
  import pyalgotrade.logger
  from pyalgotrade.optimizer import base
  from pyalgotrade.optimizer import serialization
label_desc: Use image node_id 1 to create a new Server object from inherited base classes: xmlrpc_server with example: obj = Server(paramSource, resultSinc, barFeed, address, port, autoStop, batchSize)