Run the parser in parallel

FAForever · May 5, 2024 · deb9e70 · deb9e70
1 parent c5e53ba
commit deb9e70
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/faf-commons-data/src/main/java/com/faforever/commons/replay/ReplayDataParser.java b/faf-commons-data/src/main/java/com/faforever/commons/replay/ReplayDataParser.java
@@ -66,6 +66,9 @@ public class ReplayDataParser {
   @Getter
   private List<GameOption> gameOptions;
 
+  @Getter
+  private List<Token> tokens;
+
   @Getter
   private List<Event> events;
 
@@ -441,7 +444,7 @@ private void parse() throws IOException, CompressorException {
     LittleEndianDataInputStream dataStream = new LittleEndianDataInputStream(new ByteArrayInputStream(data));
     parseHeader(dataStream);
 
-    List<Token> tokens = Tokenizer.tokenize(dataStream);
+    tokens = Tokenizer.tokenize(dataStream);
     events = Parser.parseTokens(tokens);
     interpretEvents(events);
   }

diff --git a/faf-commons-data/src/main/java/com/faforever/commons/replay/body/event/Parser.java b/faf-commons-data/src/main/java/com/faforever/commons/replay/body/event/Parser.java
@@ -11,7 +11,7 @@
 
 public class Parser {
   public static List<Event> parseTokens (List<Token> tokens) throws IOException  {
-    return tokens.stream().map((token) -> {
+    return tokens.stream().parallel().map((token) -> {
       try {
         return parseToken(token);
       } catch (Exception exception) {