process_array_threads_example.py

# process_array_threads_example.py

import threading
import multiprocessing
import time
from random import randint


# Create a function to process the items in the array/dictionary
def process_function():
	while len(items_to_process) != 0:
		item = items_to_process.pop()
		print(item)


def use_threads():
	start_time = time.time()
	items_to_process = []

	# Generate an array of random integers from 0-9
	for num in range(300):
		random_number = randint(0, 9)
		items_to_process.append(random_number)

	# Create array to hold all of the threads
	threads = []

	# Create 3 threads to process the data in the array
	for i in range(3):
		# create thread with target call of the function created above
		t = threading.Thread(target=process_function)

		# append to array of threads
		threads.append(t)
		t.start()

	# Wait for all of the threads to finish
	for thread in threads:
		thread.join()

	end_time = time.time()
	duration_in_seconds = end_time - start_time
	print("The script ran in " + str(duration_in_seconds) + " seconds.")
	
	
def use_processes():
	start_time = time.time()
	items_to_process = []

	# Generate an array of random integers from 0-9
	for num in range(300):
		random_number = randint(0, 9)
		items_to_process.append(random_number)

	# Create array to hold all of the threads
	processes = []

	# Create 3 threads to process the data in the array
	for i in range(3):
		# create thread with target call of the function created above
		p = multiprocessing.Process(target=process_function)

		# append to array of threads
		processes.append(p)
		p.start()

	# Wait for all of the threads to finish
	for process in processes:
		process.join()

	end_time = time.time()
	duration_in_seconds = end_time - start_time
	print("The script ran in " + str(duration_in_seconds) + " seconds.")