azalea/fixminer_source
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update EnhancedASTDiff.java

Browse Source 
enable forkjoin
This commit is contained in:
Anil Koyuncu
2019-08-27 12:27:45 +02:00
committed by GitHub
parent 93dd47cc8d
commit c9a54fb0e7
1 changed files with 19 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/edu/lu/uni/serval/fixminer/jobs/EnhancedASTDiff.java
+19 -19
View File
@@ -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);