code: def flush_queue(self):
      self._results = []
      if self._queue:
          json_data = json_encode(self.queue)
          send(json_data)
  
          json_reply = receive()
          decoded = json_decode(json_reply)
          if decoded.get("error", False):
              sys.stderr("ERROR: " + decoded["error"])
              sys.exit(1)
          self._results = decoded["values"]
  
imports: from __future__ import print_function
  import json
  import sys
  import socket
  import itertools
  from .None import functions
  from .None import parallel
  import math
  import multiprocessing
  import threading
label_desc: Use image node_id 15 for calling the EvalManager obj's underlying member method code with example usage: obj.flush_queue() without return types