class_docstr: Thread that processes asynchronous writes for _AsyncWriter.
docstr: Creates an _AsyncWriterThread.
  
  Args:
    queue: A Queue from which to dequeue data.
    record_writer: An instance of record_writer writer.
    flush_secs: How often, in seconds, to flush the
      pending file to disk.
docstr_tok: ["Creates","an","_AsyncWriterThread",".","Args",":","queue",":","A","Queue","from","which","to","dequeue","data",".","record_writer",":","An","instance","of","record_writer","writer",".","flush_secs",":","How","often",",","in","seconds",",","to","flush","the","pending","file","to","disk","."]
code: def __init__(self, queue, record_writer, flush_secs):
      """Creates an _AsyncWriterThread.
  
      Args:
        queue: A Queue from which to dequeue data.
        record_writer: An instance of record_writer writer.
        flush_secs: How often, in seconds, to flush the
          pending file to disk.
      """
      threading.Thread.__init__(self)
      self.daemon = True
      self.exception = None
      self._queue = queue
      self._record_writer = record_writer
      self._flush_secs = flush_secs
      # The first data will be flushed immediately.
      self._next_flush_time = 0
      self._has_pending_data = False
      self._shutdown_signal = object()
  
imports: import os
  import queue
  import socket
  import threading
  import time
  from tensorboard.compat import tf
  from tensorboard.compat.proto import event_pb2
  from tensorboard.summary.writer.record_writer import RecordWriter
label_desc: Use image node_id 1 to create a new _AsyncWriterThread object from inherited base classes: threading with example: obj = _AsyncWriterThread(queue, record_writer, flush_secs)