Username404-59
/
Yerbacon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use the deferred policy when --parallel isn't present.

This commit is contained in:
Username404-59 2021-07-06 12:23:47 +02:00
parent 61946b891f
commit 87de5ca3f4
Signed by: Username404-59
GPG Key ID: 7AB361FBB257A5D1
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main.cpp
View File

@ -28,10 +28,11 @@ int main(int argc, char* argv[]) {
} }
if (!files.empty()) { if (!files.empty()) {
const set<string_view> uniqueFiles(files.begin(), files.end()); const set<string_view> uniqueFiles(files.begin(), files.end());
vector<future<string>> units; vector<future<string>> Units;
for (string_view fileName: uniqueFiles) { for (string_view fileName: uniqueFiles) {
if (fileName != "none") { if (fileName != "none") {
future<string> newAsync = async(launch::async, [printResult, fileName, target]() mutable { const launch Policy = !parallel ? launch::deferred : launch::async;
future<string> newAsync = async(Policy, [printResult, fileName, target]() mutable {
const string transpiledString = transpile(parseString(getFileContent(fileName.data())), target); const string transpiledString = transpile(parseString(getFileContent(fileName.data())), target);
stringstream consoleOutput; stringstream consoleOutput;
if (printResult) consoleOutput << "~~~~[Yerbacon compilation result]~~~~\n\n" << "[WIP]\n" << transpiledString << "\n\n"; if (printResult) consoleOutput << "~~~~[Yerbacon compilation result]~~~~\n\n" << "[WIP]\n" << transpiledString << "\n\n";
@ -41,14 +42,10 @@ int main(int argc, char* argv[]) {
outputFileContent(outputFile, transpiledString); outputFileContent(outputFile, transpiledString);
return consoleOutput.str(); return consoleOutput.str();
}); });
if (!parallel) cout << newAsync.get(); else { Units.push_back(move(newAsync));
units.push_back(move(newAsync));
}
} }
} }
for (auto& currentThread: units) { for (auto& currentFuture: Units) cout << currentFuture.get();
cout << currentThread.get();
}
} else cout << "No valid file provided.\n"; } else cout << "No valid file provided.\n";
} }
return EXIT_SUCCESS; return EXIT_SUCCESS;