code: def __init__(self, data_queue, record_writer, flush_secs):
      threading.Thread.__init__(self)
      self.daemon = True
      self._queue = data_queue
      self._record_writer = record_writer
      self._flush_secs = flush_secs
      self._next_flush_time = 0
      self._has_pending_data = False
      self._shutdown_signal = object()
  
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 1 to create a new _AsyncWriterThread object from inherited base classes: threading with example: obj = _AsyncWriterThread(data_queue, record_writer, flush_secs)