class_docstr: DataQueue test
code: def _internal_max_size(self, DataQueueClass):
      max_size = 5
      que = DataQueueClass(
          [("url", ColumnType.SCALAR), ("image", ColumnType.QUEUE)],
          max_size,
      )
  
      size = 20
  
      def write():
          for i in range(size):
              que.put(("http://towhee.io", "image" + str(i)))
          que.seal()
  
      t = threading.Thread(target=write)
      t.start()
      time.sleep(0.01)
      self.assertEqual(que.size, max_size)
      output = []
      while True:
          ret = que.get()
          if ret is None:
              break
          output.append(ret)
          time.sleep(0.01)
          if len(output) <= size - max_size:
              self.assertEqual(que.size, max_size)
          else:
              self.assertEqual(que.size, size - len(output))
      t.join()
      self.assertTrue(que.sealed)
  
imports: import unittest
  import threading
  import time
  from functools import partial
  from towhee.runtime.data_queue import DataQueue, ColumnType, Empty
label_desc: Use image node_id 1 for calling the TestDataQueue obj's underlying member method code with example usage: obj._internal_max_size(DataQueueClass) without return types