def consumer()

in ees_sharepoint/base_command.py [0:0]

• 4 lines of code
• 2 McCabe index (conditional complexity)

    def consumer(thread_count, func):
        """Apply async calls using multithreading to the targeted function
        :param thread_count: Total number of threads to be spawned
        :param func: The target function on which the async calls would be made
        """
        with ThreadPoolExecutor(max_workers=thread_count) as executor:
            for _ in range(thread_count):
                executor.submit(func)