class_docstr: DataQueue test
code: def _internal_normal(self, DataQueueClass):
      que = DataQueueClass(
          [
              ("url", ColumnType.SCALAR),
              ("image", ColumnType.QUEUE),
              ("vec", ColumnType.QUEUE),
          ]
      )
      que.put(("http://towhee.io", "image1", "vec1"))
      self.assertEqual(que.size, 1)
      que.put(("http://towhee.io", "image2", "vec2"))
      self.assertEqual(que.size, 2)
  
      self.assertEqual(
          que._data[0]._data, "http://towhee.io"
      )  # pylint: disable=protected-access
      ret = que.get()
      self.assertEqual(ret[1], "image1")
      self.assertEqual(que.size, 1)
  
      ret = que.get()
      self.assertEqual(ret[1], "image2")
      self.assertEqual(que.size, 0)
  
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 2 for calling the TestDataQueue obj's underlying member method code with example usage: obj._internal_normal(DataQueueClass) without return types