Add Multiprocessing

MitchellShibilski-Unkel · Jan 8, 2024 · 4d09480 · 4d09480
1 parent 2a360fc
commit 4d09480
Show file tree

Hide file tree

Showing 18 changed files with 263 additions and 0 deletions.
diff --git a/Algorthmic Tests/primeCounter.py → Algorthmic_Tests/primeCounter.py b/Algorthmic Tests/primeCounter.py → Algorthmic_Tests/primeCounter.py
diff --git a/Algorthmic Tests/waveFunction.py → Algorthmic_Tests/waveFunction.py b/Algorthmic Tests/waveFunction.py → Algorthmic_Tests/waveFunction.py
diff --git a/General Computer Info/generalSpecs.py → General_Computer_Info/generalSpecs.py b/General Computer Info/generalSpecs.py → General_Computer_Info/generalSpecs.py
diff --git a/Multiprocessing/multiMergeSorting.py b/Multiprocessing/multiMergeSorting.py
@@ -0,0 +1,130 @@
+import time
+import multiprocessing as mp
+from Sorting_Tests import mergeSort
+
+
+# List to sort
+list = [nums]
+
+def multiMergeSorting(numOfCores = 6):
+    sort = mergeSort.mergeSort(list)
+
+    if numOfCores == 3:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+    elif numOfCores == 4:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+    elif numOfCores == 5:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+        p5 = mp.Process(target=sort).start()
+    elif numOfCores == 6:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+        p5 = mp.Process(target=sort).start()
+        p6 = mp.Process(target=sort).start()
+    elif numOfCores == 8:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+        p5 = mp.Process(target=sort).start()
+        p6 = mp.Process(target=sort).start()
+        p7 = mp.Process(target=sort).start()
+        p8 = mp.Process(target=sort).start()
+    elif numOfCores == 10:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+        p5 = mp.Process(target=sort).start()
+        p6 = mp.Process(target=sort).start()
+        p7 = mp.Process(target=sort).start()
+        p8 = mp.Process(target=sort).start()
+        p9 = mp.Process(target=sort).start()
+        p10 = mp.Process(target=sort).start()
+    elif numOfCores == 12:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+        p5 = mp.Process(target=sort).start()
+        p6 = mp.Process(target=sort).start()
+        p7 = mp.Process(target=sort).start()
+        p8 = mp.Process(target=sort).start()
+        p9 = mp.Process(target=sort).start()
+        p10 = mp.Process(target=sort).start()
+        p11 = mp.Process(target=sort).start()
+        p12 = mp.Process(target=sort).start()
+    elif numOfCores == 14:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+        p5 = mp.Process(target=sort).start()
+        p6 = mp.Process(target=sort).start()
+        p7 = mp.Process(target=sort).start()
+        p8 = mp.Process(target=sort).start()
+        p9 = mp.Process(target=sort).start()
+        p10 = mp.Process(target=sort).start()
+        p11 = mp.Process(target=sort).start()
+        p12 = mp.Process(target=sort).start()
+        p13 = mp.Process(target=sort).start()
+        p14 = mp.Process(target=sort).start()
+    elif numOfCores == 16:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+        p5 = mp.Process(target=sort).start()
+        p6 = mp.Process(target=sort).start()
+        p7 = mp.Process(target=sort).start()
+        p8 = mp.Process(target=sort).start()
+        p9 = mp.Process(target=sort).start()
+        p10 = mp.Process(target=sort).start()
+        p11 = mp.Process(target=sort).start()
+        p12 = mp.Process(target=sort).start()
+        p13 = mp.Process(target=sort).start()
+        p14 = mp.Process(target=sort).start()
+        p15 = mp.Process(target=sort).start()
+        p16 = mp.Process(target=sort).start()
+    elif numOfCores == 18:
+        p1 = mp.Process(target=sort).start()
+        p2 = mp.Process(target=sort).start()
+        p3 = mp.Process(target=sort).start()
+        p4 = mp.Process(target=sort).start()
+        p5 = mp.Process(target=sort).start()
+        p6 = mp.Process(target=sort).start()
+        p7 = mp.Process(target=sort).start()
+        p8 = mp.Process(target=sort).start()
+        p9 = mp.Process(target=sort).start()
+        p10 = mp.Process(target=sort).start()
+        p11 = mp.Process(target=sort).start()
+        p12 = mp.Process(target=sort).start()
+        p13 = mp.Process(target=sort).start()
+        p14 = mp.Process(target=sort).start()
+        p15 = mp.Process(target=sort).start()
+        p16 = mp.Process(target=sort).start()
+        p17 = mp.Process(target=sort).start()
+        p18 = mp.Process(target=sort).start()
+    else:
+        pass
+
+# Start timer
+startTimer = time.perf_counter()
+startTimer2 = time.process_time()
+
+multiMergeSorting(numOfCores)
+
+endTimer = time.perf_counter()
+endTimer2 = time.process_time()
+
+print(f"Task Finished In Performance: {endTimer - startTimer:0.8f}s\nTask Finished In Process/CPU/Kernel + User Space: {endTimer2 - startTimer2:0.8f}s")
diff --git a/Multiprocessing/multiPrimeCounters.py b/Multiprocessing/multiPrimeCounters.py
@@ -0,0 +1,128 @@
+import time
+import multiprocessing as mp
+from Algorthmic_Tests import primeCounter
+
+
+def multiPrimeCounting(numOfCores = 6, countTo = 1001):
+    counter = primeCounter.primeCounter(countTo)
+
+    if numOfCores == 3:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+    elif numOfCores == 4:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+    elif numOfCores == 5:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+        p5 = mp.Process(target=counter).start()
+    elif numOfCores == 6:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+        p5 = mp.Process(target=counter).start()
+        p6 = mp.Process(target=counter).start()
+    elif numOfCores == 8:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+        p5 = mp.Process(target=counter).start()
+        p6 = mp.Process(target=counter).start()
+        p7 = mp.Process(target=counter).start()
+        p8 = mp.Process(target=counter).start()
+    elif numOfCores == 10:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+        p5 = mp.Process(target=counter).start()
+        p6 = mp.Process(target=counter).start()
+        p7 = mp.Process(target=counter).start()
+        p8 = mp.Process(target=counter).start()
+        p9 = mp.Process(target=counter).start()
+        p10 = mp.Process(target=counter).start()
+    elif numOfCores == 12:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+        p5 = mp.Process(target=counter).start()
+        p6 = mp.Process(target=counter).start()
+        p7 = mp.Process(target=counter).start()
+        p8 = mp.Process(target=counter).start()
+        p9 = mp.Process(target=counter).start()
+        p10 = mp.Process(target=counter).start()
+        p11 = mp.Process(target=counter).start()
+        p12 = mp.Process(target=counter).start()
+    elif numOfCores == 14:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+        p5 = mp.Process(target=counter).start()
+        p6 = mp.Process(target=counter).start()
+        p7 = mp.Process(target=counter).start()
+        p8 = mp.Process(target=counter).start()
+        p9 = mp.Process(target=counter).start()
+        p10 = mp.Process(target=counter).start()
+        p11 = mp.Process(target=counter).start()
+        p12 = mp.Process(target=counter).start()
+        p13 = mp.Process(target=counter).start()
+        p14 = mp.Process(target=counter).start()
+    elif numOfCores == 16:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+        p5 = mp.Process(target=counter).start()
+        p6 = mp.Process(target=counter).start()
+        p7 = mp.Process(target=counter).start()
+        p8 = mp.Process(target=counter).start()
+        p9 = mp.Process(target=counter).start()
+        p10 = mp.Process(target=counter).start()
+        p11 = mp.Process(target=counter).start()
+        p12 = mp.Process(target=counter).start()
+        p13 = mp.Process(target=counter).start()
+        p14 = mp.Process(target=counter).start()
+        p15 = mp.Process(target=counter).start()
+        p16 = mp.Process(target=counter).start()
+    elif numOfCores == 18:
+        p1 = mp.Process(target=counter).start()
+        p2 = mp.Process(target=counter).start()
+        p3 = mp.Process(target=counter).start()
+        p4 = mp.Process(target=counter).start()
+        p5 = mp.Process(target=counter).start()
+        p6 = mp.Process(target=counter).start()
+        p7 = mp.Process(target=counter).start()
+        p8 = mp.Process(target=counter).start()
+        p9 = mp.Process(target=counter).start()
+        p10 = mp.Process(target=counter).start()
+        p11 = mp.Process(target=counter).start()
+        p12 = mp.Process(target=counter).start()
+        p13 = mp.Process(target=counter).start()
+        p14 = mp.Process(target=counter).start()
+        p15 = mp.Process(target=counter).start()
+        p16 = mp.Process(target=counter).start()
+        p17 = mp.Process(target=counter).start()
+        p18 = mp.Process(target=counter).start()
+    else:
+        pass
+
+# Start timer
+startTimer = time.perf_counter()
+startTimer2 = time.process_time()
+
+# Start prime counter
+multiPrimeCounting(numOfCores, countTo)
+
+endTimer = time.perf_counter()
+endTimer2 = time.process_time()
+
+print(f"Task Finished In Performance: {endTimer - startTimer:0.8f}s\nTask Finished In Process/CPU/Kernel + User Space: {endTimer2 - startTimer2:0.8f}s")
diff --git a/README.md b/README.md
@@ -43,3 +43,8 @@ IDE Links:
 - This adds more complex tasks/algorithms
     - Wave Function
     - Prime Counter 
+
+# Multiprocessing
+- This uses current tests in PyPC and uses multiprocessing to max out your CPU to test how fast your computer can process a task under heavy load
+    - Merge Sorting
+    - Prime Counting
diff --git a/Simple Tests/addTest.py → Simple_Tests/addTest.py b/Simple Tests/addTest.py → Simple_Tests/addTest.py
diff --git a/Simple Tests/allBasicMath.py → Simple_Tests/allBasicMath.py b/Simple Tests/allBasicMath.py → Simple_Tests/allBasicMath.py
diff --git a/Simple Tests/divideTest.py → Simple_Tests/divideTest.py b/Simple Tests/divideTest.py → Simple_Tests/divideTest.py
diff --git a/Simple Tests/forBreakTest.py → Simple_Tests/forBreakTest.py b/Simple Tests/forBreakTest.py → Simple_Tests/forBreakTest.py
diff --git a/Simple Tests/forTest.py → Simple_Tests/forTest.py b/Simple Tests/forTest.py → Simple_Tests/forTest.py
diff --git a/Simple Tests/input.py → Simple_Tests/input.py b/Simple Tests/input.py → Simple_Tests/input.py
diff --git a/Simple Tests/mulitplyTest.py → Simple_Tests/mulitplyTest.py b/Simple Tests/mulitplyTest.py → Simple_Tests/mulitplyTest.py
diff --git a/Simple Tests/subText.py → Simple_Tests/subText.py b/Simple Tests/subText.py → Simple_Tests/subText.py
diff --git a/Sorting Tests/bubbleSort.py → Sorting_Tests/bubbleSort.py b/Sorting Tests/bubbleSort.py → Sorting_Tests/bubbleSort.py
diff --git a/Sorting Tests/greatestAndLeastSort.py → Sorting_Tests/greatestAndLeastSort.py b/Sorting Tests/greatestAndLeastSort.py → Sorting_Tests/greatestAndLeastSort.py
diff --git a/Sorting Tests/mergeSort.py → Sorting_Tests/mergeSort.py b/Sorting Tests/mergeSort.py → Sorting_Tests/mergeSort.py
diff --git a/Sorting Tests/selectionSort.py → Sorting_Tests/selectionSort.py b/Sorting Tests/selectionSort.py → Sorting_Tests/selectionSort.py