From c9a54fb0e73d5d5d990c4b8f93d895a7e78ece3e Mon Sep 17 00:00:00 2001
From: Anil Koyuncu <38783717+anilkoyuncu@users.noreply.github.com>
Date: Tue, 27 Aug 2019 12:27:45 +0200
Subject: [PATCH] Update EnhancedASTDiff.java

enable forkjoin
---
 .../serval/fixminer/jobs/EnhancedASTDiff.java | 38 +++++++++----------
 1 file changed, 19 insertions(+), 19 deletions(-)

diff --git a/src/main/java/edu/lu/uni/serval/fixminer/jobs/EnhancedASTDiff.java b/src/main/java/edu/lu/uni/serval/fixminer/jobs/EnhancedASTDiff.java
index a9f51ec..25bdd5e 100755
--- a/src/main/java/edu/lu/uni/serval/fixminer/jobs/EnhancedASTDiff.java
+++ b/src/main/java/edu/lu/uni/serval/fixminer/jobs/EnhancedASTDiff.java
@@ -91,25 +91,25 @@ public class EnhancedASTDiff {
 				}
 				break;
 			case "FORKJOIN":
-//				int counter = new Object() {
-//					int counter = 0;
-//
-//					{
-//						allMessageFiles.stream().
-//								parallel().
-//								peek(x -> counter++).
-//								forEach(m ->
-//										{
-//											EDiffHunkParser parser =  new EDiffHunkParser();
-//											parser.parseFixPatterns(m.getPrevFile(),m.getRevFile(), m.getDiffEntryFile(),project,msg.getInnerPool());
-//											if (counter % 10 == 0) {
-//												log.info("Finalized parsing " + counter + " files... remaing " + (allMessageFiles.size() - counter));
-//											}
-//										}
-//								);
-//					}
-//				}.counter;
-//				log.info("Finished parsing {} files",counter);
+				int counter = new Object() {
+					int counter = 0;
+
+					{
+						allMessageFiles.stream().
+								parallel().
+								peek(x -> counter++).
+								forEach(m ->
+										{
+											EDiffHunkParser parser =  new EDiffHunkParser();
+											parser.parseFixPatterns(m.getPrevFile(),m.getRevFile(), m.getDiffEntryFile(),project,msg.getInnerPool());
+											if (counter % 10 == 0) {
+												log.info("Finalized parsing " + counter + " files... remaing " + (allMessageFiles.size() - counter));
+											}
+										}
+								);
+					}
+				}.counter;
+				log.info("Finished parsing {} files",counter);
 				break;
 			default:
 				log.error("Unknown parallelism {}", parallelism);