Add the rayon and rayon_sorted algorithms

Cargo.toml

@@ -9,11 +9,12 @@ publish = false
 
 [dependencies]
 pbkdf2 = "0.12.2"
+rayon = { version = "1.10.0", default-features = false }
 sha2 = "0.10.8"
 
 [dev-dependencies]
 criterion = { version = "0.5.1", features = ["html_reports"] }
 
 [[bench]]
-name = "small"
+name = "job_scheduling"
 harness = false

README.md

@@ -23,9 +23,8 @@ the [optimal job scheduling problem][ojs problem] and can often be seen as a
 
 ### Example
 
-If we have 4 tasks tasks to execute. Three of then takes 1 second each to
+We have 4 tasks tasks to execute. Three of them takes 1 second each to execute
-execute and the last one takes 3 seconds. We have 2 processing units of equal
+and the last one takes 3 seconds. We have 2 processing units of equal power.
-power.
 
 If each processing unit starts by executing one of the 1s tasks, they will both
 finis this job after one second. Then, one of those processing unit will

benches/job_scheduling.rs

@@ -0,0 +1,26 @@
+use criterion::{criterion_group, criterion_main, BenchmarkId, Criterion};
+use rust_job_scheduling::algorithm::*;
+use rust_job_scheduling::data::SMALL;
+use rust_job_scheduling::Task;
+
+const TEST_DATA: &[(&str, &[Task])] = &[("small", SMALL)];
+const TEST_FUNCS: &[(&str, &dyn Fn(&[Task]))] = &[
+	("single thread", &single_thread),
+	("rayon", &rayon),
+	("rayon sorted", &rayon_sorted),
+];
+
+fn job_scheduling_benchmark(c: &mut Criterion) {
+	let mut group = c.benchmark_group("job_scheduling");
+	for (data_name, data) in TEST_DATA {
+		for (func_name, func) in TEST_FUNCS {
+			group.bench_with_input(BenchmarkId::new(*func_name, data_name), data, |b, i| {
+				b.iter(|| func(i))
+			});
+		}
+	}
+	group.finish();
+}
+
+criterion_group!(benches, job_scheduling_benchmark);
+criterion_main!(benches);

benches/small.rs

@@ -1,12 +0,0 @@
-use criterion::{black_box, criterion_group, criterion_main, Criterion};
-use rust_job_scheduling::algorithm::*;
-use rust_job_scheduling::data::SMALL;
-
-fn criterion_benchmark(c: &mut Criterion) {
-	c.bench_function("single thread", |b| {
-		b.iter(|| single_thread(black_box(SMALL)))
-	});
-}
-
-criterion_group!(benches, criterion_benchmark);
-criterion_main!(benches);

src/algorithm.rs

@@ -1,3 +1,5 @@
+mod rayon;
 mod single_thread;
 
+pub use rayon::{rayon, rayon_sorted};
 pub use single_thread::single_thread;

src/algorithm/rayon.rs

@@ -0,0 +1,12 @@
+use crate::Task;
+use rayon::prelude::*;
+
+pub fn rayon(data: &[Task]) {
+	data.into_par_iter().for_each(|task| task.execute());
+}
+
+pub fn rayon_sorted(data: &[Task]) {
+	let mut data = data.to_vec();
+	data.sort();
+	rayon(&data)
+}