code: def stop(self):
      self._queue.put(self._shutdown_signal)
      self.join()
  
imports: from visualdl.io import bfile
  from visualdl.utils.crc32 import masked_crc32c
  from visualdl.proto import record_pb2
  import struct
  import time
  import queue
  import threading
  import os
label_desc: Use image node_id 2 for calling the _AsyncWriterThread obj's underlying member method code with example usage: obj.stop() without return types