code: def test_lazy_init(self):
      run = [False]
  
      def thread_go(q):
          def go():
              q.get(timeout=0.1)
  
          with expect_raises(queue.Empty):
              asyncio.run(greenlet_spawn(go))
          run[0] = True
  
      t = threading.Thread(
          target=thread_go, args=[queue.AsyncAdaptedQueue()]
      )
      t.start()
      t.join()
  
      is_true(run[0])
  
imports: import asyncio
  import contextvars
  from multiprocessing import get_context
  import random
  import threading
  from sqlalchemy import exc
  from sqlalchemy import testing
  from sqlalchemy.testing import async_test
  from sqlalchemy.testing import eq_
  from sqlalchemy.testing import expect_raises
  from sqlalchemy.testing import expect_raises_message
  from sqlalchemy.testing import fixtures
  from sqlalchemy.testing import is_true
  from sqlalchemy.testing.config import combinations
  from sqlalchemy.util import await_
  from sqlalchemy.util import greenlet_spawn
  from sqlalchemy.util import queue
  from ._concurrency_fixtures import greenlet_not_imported
  from ._concurrency_fixtures import greenlet_setup_in_ext
  from ._concurrency_fixtures import greenlet_setup_on_call
label_desc: Use image node_id 1 for calling the TestAsyncAdaptedQueue obj's underlying member method code with example usage: obj.test_lazy_init() without return types