Implement threading in a checker pattern

vitor-k · Nov 2, 2019 · 98b7a06 · 98b7a06
1 parent d24bc57
commit 98b7a06
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/RayTracer/RayTracer/RayTracer.cpp b/RayTracer/RayTracer/RayTracer.cpp
@@ -42,10 +42,15 @@ class RayTracerEngine : public olc::PixelGameEngine {
 	float totalTime = 0;
 
 	void drawingThread(int start, int end, int32_t width, int32_t height, olc::Pixel* tela) {
-		for (int i = start; i < end && i<width*height; i++) {
+		for (int i = start; i < end; i++) {
 			tela[i] = inicialTrace(i%width - width / 2, i/width - height / 2);
 		}
 	}
+	void drawingThread2(int offset, int32_t width, int32_t height, olc::Pixel* tela) {
+		for (int i = 0; i * nThreads + offset < width * height; i++) {
+			tela[i*nThreads + offset] = inicialTrace((i * nThreads + offset) % width - width / 2, (i * nThreads + offset) / width - height / 2);
+		}
+	}
 	bool OnUserUpdate(float fElapsedTime) override {
 		totalTime += 0.1f;
 		sceneObjects[0]->center.x = 10 + 8 *cos(1 * totalTime) + 2 * sin(3*totalTime);
@@ -60,9 +65,13 @@ class RayTracerEngine : public olc::PixelGameEngine {
 		olc::Pixel *tela = new olc::Pixel[width * height];
 
 		std::thread threads[nThreads];
-		for (int i = 0; i < nThreads; i++) {
+		/*for (int i = 0; i < nThreads; i++) {
 			threads[i] = std::thread(&RayTracerEngine::drawingThread, this, i * width * height / nThreads, (i + 1) * width * height / nThreads, width, height, tela);
+		}*/
+		for (int i = 0; i < nThreads; i++) {
+			threads[i] = std::thread(&RayTracerEngine::drawingThread2, this, i, width, height, tela);
 		}
+
 		for (int i = 0; i < nThreads; i++) {
 			threads[i].join();
 		}