feat: Change result to numpy array in numpy functions, add multithreading in some functions

Author: WrldEngine

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rem_math"
-version = "0.1.6"
+version = "0.1.7"
 edition = "2021"
 
 [lib]

benches/common.rs

@@ -53,17 +53,25 @@ fn sum_two_floats32_with_mthreaded_benchmark(c: &mut Criterion) {
 fn sum_two_ints32_with_benchmark(c: &mut Criterion) {
     let arr = black_box(vec![1; NUM_ITERATIONS]);
     c.bench_function("Array accumulation of two integer arrays", |b| {
-        b.iter(|| sum_two_ints32(&arr, &arr, false))
+        b.iter(|| sum_two_ints32(&arr, &arr, ""))
     });
 }
 
 fn sum_two_ints32_with_simd_benchmark(c: &mut Criterion) {
     let arr = black_box(vec![1; NUM_ITERATIONS]);
     c.bench_function("Array accumulation of two integer arrays with SIMD", |b| {
-        b.iter(|| sum_two_ints32(&arr, &arr, true))
+        b.iter(|| sum_two_ints32(&arr, &arr, "simd"))
     });
 }
 
+fn sum_two_ints32_with_mthreaded_benchmark(c: &mut Criterion) {
+    let arr = black_box(vec![1; NUM_ITERATIONS]);
+    c.bench_function(
+        "Array accumulation of two integer arrays with multi threading",
+        |b| b.iter(|| sum_two_ints32(&arr, &arr, "threading")),
+    );
+}
+
 fn mul_two_ints32_benchmark(c: &mut Criterion) {
     let arr = black_box(vec![1; NUM_ITERATIONS]);
     c.bench_function("Array multiply of two integer arrays", |b| {
@@ -95,6 +103,7 @@ criterion_group!(
     sum_two_floats32_with_mthreaded_benchmark,
     sum_two_ints32_with_benchmark,
     sum_two_ints32_with_simd_benchmark,
+    sum_two_ints32_with_mthreaded_benchmark,
     mul_two_ints32_benchmark,
     mul_two_ints32_with_simd_benchmark,
     mul_two_ints32_with_mthreaded_benchmark,

benches/common_benchmark_test.py

@@ -5,11 +5,17 @@
 
 NUM_ITERATIONS = 10_000_000
 
+
 @pytest.fixture(scope="module")
 def large_array():
     return np.array([i for i in range(NUM_ITERATIONS)], dtype=np.int32)
 
 
+@pytest.fixture(scope="module")
+def large_naive_array():
+    return [i for i in range(NUM_ITERATIONS)]
+
+
 @pytest.mark.benchmark(
     group="numpy_sum",
     min_time=0.1,
@@ -73,7 +79,7 @@ def result():
 def test_rm_mul(benchmark, large_array):
     @benchmark
     def result():
-        return rm.multiply_two_nparr_ints32(large_array, large_array, method="simd")
+        return rm.multiply_two_nparr_ints32(large_array, large_array, "threading")
 
     assert result is not None
 
@@ -107,6 +113,6 @@ def result():
 def test_rm_sum_two_ints32(benchmark, large_array):
     @benchmark
     def result():
-        return rm.sum_two_nparr_ints32(large_array, large_array)
+        return rm.sum_two_nparr_ints32(large_array, large_array, "threading")
 
     assert result is not None

benches/numpy_compare_benchmark_test.py benches/compare_benchmark_test.pybenches/numpy_compare_benchmark_test.py renamed to benches/compare_benchmark_test.py

@@ -1,6 +1,6 @@
 [project]
 name = "rem_math"
-version = "0.1.6"
+version = "0.1.7"
 description = ""
 authors = [
     {name = "WrldEngine",email = "kamran_pulatov@outlook.com"}

benches/mul_of_arrays_benchmark_test.py

@@ -10,8 +10,8 @@ def sum_two_floats32(arr_1: List[float], arr_2: List[float], method: str) -> Lis
 def sum_two_nparr_ints32(
     arr_1: List[int] | NDArray, arr_2: List[int] | NDArray, method: str
 ) -> List: ...
-def sum_two_ints32(arr_1: List[int], arr_2: List[int]) -> List: ...
+def sum_two_ints32(arr_1: List[int], arr_2: List[int], method: str) -> List: ...
 def multiply_two_nparr_ints32(
-    arr_1: List[int] | NDArray, arr_2: List[int] | NDArray
+    arr_1: List[int] | NDArray, arr_2: List[int] | NDArray, method: str
 ) -> List: ...
 def multiply_two_ints32(arr_1: List[int], arr_2: List[int], method: str) -> List: ...