threading_example.py

import random
import threading
import time
from queue import Queue

NUM_COUNT = 10_000_000
NUM_THREADS = 4

print(f"Generating {NUM_COUNT} random numbers...")
nums = [random.randint(1, 100) for _ in range(NUM_COUNT)]

# Single-threaded sum
def single_threaded_sum(numbers):
    start_time = time.time()
    total = sum(numbers)
    end_time = time.time()
    return total, end_time - start_time

def part_sum(numbers_part, result_queue):
    result_queue.put(sum(numbers_part))

# Multithreaded sum
def multithreaded_sum(numbers, num_threads=NUM_THREADS):
    start_time = time.time()
    part_size = len(numbers) // num_threads
    threads = []
    result_queue = Queue()

    # Divide the list into parts and create threads
    for i in range(num_threads):
        start_index = i * part_size
        end_index = start_index + part_size if i < num_threads - 1 else len(numbers)
        part = numbers[start_index:end_index]
        thread = threading.Thread(target=part_sum, args=(part, result_queue))
        threads.append(thread)
        thread.start()

    for thread in threads:
        thread.join()

    total = sum(result_queue.get() for _ in range(num_threads))
    end_time = time.time()
    return total, end_time - start_time

# Run single-threaded sum
print("\nRunning single-threaded sum...")
single_total, single_time = single_threaded_sum(nums)
print(f"Single-threaded Sum: {single_total}")

# Run multithreaded sum
print("\nRunning multithreaded sum...")
multi_total, multi_time = multithreaded_sum(nums)
print(f"Multithreaded Sum: {multi_total}")

# Comparison
print("\nComparison of Results:")
print(f"{'Approach':<25} {'Time (seconds)':>15}")
print(f"{'Single-threaded':<25} {single_time:>10.5f}")
print(f"{'Multithreaded':<25} {multi_time:>10.5f}")
speedup = single_time / multi_time if multi_time > 0 else float('inf')
print(f"Speedup Factor: {speedup:.2f}x")