Revise test function names and some comments.

Author: shunping

sdks/python/apache_beam/transforms/async_dofn_test.py

@@ -489,7 +489,7 @@ def add_item(i):
       self.assertEqual(bag_states['key' + str(i)].items, [])
 
   @staticmethod
-  def _run_reset_state_deadlock_scenario(use_asyncio):
+  def _run_reset_state_concurrent_teardown(use_asyncio):
     dofn = BasicDofn(sleep_time=0.5)
     async_dofn = async_lib.AsyncWrapper(dofn, use_asyncio=use_asyncio)
     async_dofn.setup()
@@ -500,16 +500,15 @@ def _run_reset_state_deadlock_scenario(use_asyncio):
     async_dofn.process(('key1', 1), to_process=fake_bag_state, timer=fake_timer)
     time.sleep(0.05)
 
-    # Attempt to call reset_state(). If the fix is NOT applied, this will deadlock
-    # forever because reset_state() holds the lock while waiting for active tasks/threads,
-    # blocking the future's done callback from acquiring the lock.
+    # Verify that calling reset_state() while background tasks are actively running
+    # completes cleanly without causing lock-ordering deadlocks.
     async_lib.AsyncWrapper.reset_state()
 
-  def test_reset_state_hang_reproduction(self):
-    # Run the deadlock scenario in a separate process so that if it hangs,
-    # we can terminate it without causing the main pytest process to hang at exit.
+  def test_reset_state_concurrent_teardown(self):
+    # Verify concurrent teardown safety in a separate process to prevent any potential
+    # regressions from freezing the main pytest process at exit.
     p = multiprocessing.Process(
-        target=AsyncTest._run_reset_state_deadlock_scenario,
+        target=AsyncTest._run_reset_state_concurrent_teardown,
         args=(self.use_asyncio, ))
     p.start()
     p.join(timeout=10.0)