code: def test_concurrent_execution() -> None:
      runner = Runner()
      caller_threads = []
  
      result_list: list[str] = []
      result_list_lock = Lock()
  
      def target(
          count: int, r_list: list[str], r_list_lock: Lock
      ) -> None:
          result = runner.run(
              py2cmd(
                  "import time;"
                  "import sys;"
                  "time.sleep(1);"
                  "print('end', sys.argv[1])",
                  str(count),
              ),
              protocol=StdOutCapture,
          )
          assert isinstance(result, dict)
          output = result["stdout"].strip()
          assert output == f"end {str(count)}"
          with r_list_lock:
              r_list.append(output)
  
      for c in range(100):
          caller_thread = Thread(
              target=target,
              kwargs=dict(
                  count=c,
                  r_list=result_list,
                  r_list_lock=result_list_lock,
              ),
          )
          caller_thread.start()
          caller_threads.append(caller_thread)
  
      while caller_threads:
          t = caller_threads.pop()
          t.join()
  
      assert len(result_list) == 100
  
imports: from __future__ import annotations
  import logging
  import os
  import signal
  import sys
  import unittest.mock
  from threading import Lock, Thread
  from time import sleep, time
  from typing import Any
  import pytest
  from datalad.tests.utils_pytest import OBSCURE_FILENAME, SkipTest, assert_cwd_unchanged, assert_in, assert_raises, eq_, integration, ok_, ok_file_has_content, skip_if_on_windows, swallow_logs, with_tempfile
  from datalad.utils import CMD_MAX_ARG, Path, on_windows
  from ..None import CommandError, KillOutput, Protocol, Runner, StdOutCapture, StdOutErrCapture
  from .utils import py2cmd
label_desc: Use image node_id 22 for calling a global function with example usage: test_concurrent_execution() without return types