Parallel Extract Multiple Sources with Threads in Python

import threading
from concurrent.futures import ThreadPoolExecutor

def extract_from_source(source):
    """Simulate extracting data from a source."""
    return f"Data from {source}"

def main():
    sources = ["source_a", "source_b", "source_c", "source_d"]
    
    # Sequential extraction for comparison
    sequential_results = [extract_from_source(s) for s in sources]
    print("Sequential results:", sequential_results)
    
    # Parallel extraction using ThreadPoolExecutor
    with ThreadPoolExecutor(max_workers=4) as executor:
        parallel_results = list(executor.map(extract_from_source, sources))
    print("Parallel results:  ", parallel_results)

    # Verify both approaches produce the same output
    assert sequential_results == parallel_results, "Mismatch between sequential and parallel results"
    print("Both approaches produced identical results.")

if __name__ == "__main__":
    main()