class_docstr: DataQueue test
code: def _internal_all_scalar_multithread(self, DataQueueClass):
      input_que = DataQueueClass(
          [("url", ColumnType.SCALAR), ("image", ColumnType.SCALAR)]
      )
  
      def write():
          input_que.put_dict({"url": 1})
          time.sleep(0.05)
          input_que.put_dict({"image": 2})
          input_que.seal()
  
      t = threading.Thread(target=write)
      t.start()
  
      ret = []
      while True:
          data = input_que.get()
          if data is None:
              break
          ret.append(data)
      self.assertEqual(ret, [[1, 2]])
      t.join()
  
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 12 for calling the TestDataQueue obj's underlying member method code with example usage: obj._internal_all_scalar_multithread(DataQueueClass) without return types