diff --git a/python/main.py b/python/main.py index 2d64c2742bec82fa345b207a4f4cabb0abdc05a1..04f5599bd12869e6689008847bf6f631844d095a 100644 --- a/python/main.py +++ b/python/main.py @@ -37,21 +37,48 @@ if __name__ == '__main__': user_menu_choice = user_menu() if user_menu_choice == '1': + # Run Safe Multi-Processing. logger.info('Running "Unsafe Multi-Processing" Example.') logger.info('') Parallelism(False, multi_process=True) + elif user_menu_choice == '2': + # Run Safe Multi-Processing. + logger.info("Run safe multi-processing on loop?") + user_input = str(input('')).strip() logger.info('Running "Safe Multi-Processing" Example.') - logger.info('') - Parallelism(True, multi_process=True) + + if user_input[0] == 'Y' or user_input[0] == 'y': + logger.info('') + logger.info('') + logger.info('Program will loop until cancelled with ctrl+c.') + logger.info('') + while True: + Parallelism(True, multi_process=True) + else: + Parallelism(True, multi_process=True) + elif user_menu_choice == '3': + # Run Unsafe Multi-Threading. logger.info('Running "Unsafe Multi-Threading" Example.') logger.info('') Parallelism(False, multi_thread=True) + elif user_menu_choice == '4': + # Run Safe Multi-Threading. + logger.info("Run \"Safe Multi-Threading\" on loop?") + user_input = str(input('')).strip() logger.info('Running "Safe Multi-Threading" Example.') - logger.info('') - Parallelism(True, multi_thread=True) + + if user_input[0] == 'Y' or user_input[0] == 'y': + logger.info('') + logger.info('') + logger.info('Program will loop until cancelled with ctrl+c.') + logger.info('') + while True: + Parallelism(True, multi_thread=True) + else: + Parallelism(True, multi_thread=True) else: logger.info('Unrecognized user menu choice.') logger.info('') diff --git a/python/resources/parallelism.py b/python/resources/parallelism.py index ce93b0ccf25562a3f5ac024e1d1f518c4a9010f7..a61fb6d5a6749223245e3e4dd83794dae4d4f3b2 100644 --- a/python/resources/parallelism.py +++ b/python/resources/parallelism.py @@ -64,9 +64,9 @@ class Parallelism(): shared_lock = manager.Value('i', 0, lock=False) # Create a shared int. shared_counter = manager.Value('i', 0, lock=False) - logger.info('Created shared Flag: {0}'.format(shared_flag)) - logger.info('Created shared Lock: {0}'.format(shared_lock)) - logger.info('Created shared Counter: {0}'.format(shared_counter)) + logger.debug('Created shared Flag: {0}'.format(shared_flag)) + logger.debug('Created shared Lock: {0}'.format(shared_lock)) + logger.debug('Created shared Counter: {0}'.format(shared_counter)) logger.info('Creating processes/threads.') logger.info('')