code: def test_series_reductions_concurrency(method):
      e = ThreadPoolExecutor(10)
  
      np.random.seed(0)
      srs = [cudf.Series(np.random.random(10000)) for _ in range(1)]
  
      def call_test(sr):
          fn = getattr(sr, method)
          if method in ["std", "var"]:
              return fn(ddof=1)
          else:
              return fn()
  
      def f(sr):
          return call_test(sr + 1)
  
      list(e.map(f, srs * 50))
  
imports: from concurrent.futures import ThreadPoolExecutor
  import cupy
  import numpy
  import pandas
  import pytest
  import cudf
  from cudf.datasets import randomdata
  from cudf.testing._utils import _create_cudf_series_float64_default, _create_pandas_series_float64_default, assert_eq, assert_exceptions_equal, expect_warning_if
label_desc: Use image node_id 2 for calling a global function with example usage: test_series_reductions_concurrency(method) and returns: call_test, fn, fn