Ensure that content is complete using a queue

BUILD

@@ -94,6 +94,7 @@ swift_library(
         ":SourceKittenFramework.wrapper",
         "@sourcekitten_com_github_jpsim_yams//:Yams",
         "@swiftlint_com_github_scottrhoyt_swifty_text_table//:SwiftyTextTable",
+        "@com_github_mattmassicotte_queue//:Queue",
     ] + select({
         "@platforms//os:linux": ["@com_github_krzyzanowskim_cryptoswift//:CryptoSwift"],
         "//conditions:default": [":DyldWarningWorkaround"],

MODULE.bazel

@@ -19,6 +19,7 @@ swiftlint_repos = use_extension("//bazel:repos.bzl", "swiftlint_repos_bzlmod")
 use_repo(
     swiftlint_repos,
     "com_github_johnsundell_collectionconcurrencykit",
+    "com_github_mattmassicotte_queue",
     "com_github_krzyzanowskim_cryptoswift",
     "swiftlint_com_github_scottrhoyt_swifty_text_table",
 )

Package.resolved

@@ -18,6 +18,15 @@
         "version" : "1.8.4"
       }
     },
+    {
+      "identity" : "queue",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/mattmassicotte/Queue",
+      "state" : {
+        "revision" : "6adf359a705e3252742905b413bb8f56401043ca",
+        "version" : "0.2.0"
+      }
+    },
     {
       "identity" : "sourcekitten",
       "kind" : "remoteSourceControl",

Package.swift

@@ -37,6 +37,7 @@ let package = Package(
         .package(url: "https://github.com/scottrhoyt/SwiftyTextTable.git", from: "0.9.0"),
         .package(url: "https://github.com/JohnSundell/CollectionConcurrencyKit.git", from: "0.2.0"),
         .package(url: "https://github.com/krzyzanowskim/CryptoSwift.git", .upToNextMinor(from: "1.8.4")),
+        .package(url: "https://github.com/mattmassicotte/Queue", from: "0.2.0"),
     ],
     targets: [
         .executableTarget(
@@ -91,6 +92,7 @@ let package = Package(
                 .product(name: "SwiftSyntaxBuilder", package: "swift-syntax"),
                 .product(name: "SwiftyTextTable", package: "SwiftyTextTable"),
                 .product(name: "Yams", package: "Yams"),
+                .product(name: "Queue", package: "Queue"),
                 "SwiftLintCoreMacros",
             ],
             swiftSettings: swiftFeatures + strictConcurrency

Source/SwiftLintCore/Models/Issue.swift

@@ -1,4 +1,5 @@
 import Foundation
+import Queue
 
 /// All possible SwiftLint issues which are printed as warnings by default.
 public enum Issue: LocalizedError, Equatable {
@@ -85,6 +86,7 @@ public enum Issue: LocalizedError, Equatable {
     package nonisolated(unsafe) static var printDeprecationWarnings = true
 
     @TaskLocal private static var messageConsumer: (@Sendable (String) -> Void)?
+    @TaskLocal private static var printQueue: AsyncQueue?
 
     /// Hook used to capture all messages normally printed to stdout and return them back to the caller.
     ///
@@ -101,12 +103,19 @@ public enum Issue: LocalizedError, Equatable {
         defer {
             Console.content = ""
         }
-        try $messageConsumer.withValue(
-            { Console.content += (Console.content.isEmpty ? "" : "\n") + $0 },
-            operation: runner
+        let queue = AsyncQueue()
+        try $printQueue.withValue(
+            queue,
+            operation: {
+                try $messageConsumer.withValue(
+                    { Console.content += (Console.content.isEmpty ? "" : "\n") + $0 },
+                    operation: runner
+                )
+            }
         )
-        await Task.yield()
-        return Console.content
+        return await queue.addBarrierOperation {
+            Console.content
+        }.value
     }
 
     /// Wraps any `Error` into a `SwiftLintError.genericWarning` if it is not already a `SwiftLintError`.
@@ -140,13 +149,10 @@ public enum Issue: LocalizedError, Equatable {
         if case .ruleDeprecated = self, !Self.printDeprecationWarnings {
             return
         }
-        Task(priority: .high) { @MainActor in
-            if let consumer = Self.messageConsumer {
-                consumer(errorDescription)
-            } else {
-                queuedPrintError(errorDescription)
-            }
+        Self.printQueue?.addOperation {
+            Self.messageConsumer?(errorDescription)
         }
+        queuedPrintError(errorDescription)
     }
 
     private var message: String {

bazel/Queue.BUILD

@@ -0,0 +1,11 @@
+load(
+    "@build_bazel_rules_swift//swift:swift.bzl",
+    "swift_library",
+)
+
+swift_library(
+    name = "Queue",
+    srcs = glob(["Sources/Queue/*.swift"]),
+    module_name = "Queue",
+    visibility = ["//visibility:public"],
+)

bazel/repos.bzl

@@ -56,6 +56,14 @@ def swiftlint_repos(bzlmod = False):
         url = "https://github.com/JohnSundell/CollectionConcurrencyKit/archive/refs/tags/0.2.0.tar.gz",
     )
 
+    http_archive(
+        name = "com_github_mattmassicotte_queue",
+        sha256 = "2c00cde22406d868b2341432c119c73d0c1a8ce40a663469b1b8cc5c39007737",
+        build_file = "@SwiftLint//bazel:Queue.BUILD",
+        strip_prefix = "Queue-0.2.0",
+        url = "https://github.com/mattmassicotte/Queue/archive/refs/tags/0.2.0.tar.gz",
+    )
+
     http_archive(
         name = "com_github_krzyzanowskim_cryptoswift",
         sha256 = "69b23102ff453990d03aff4d3fabd172d0667b2b3ed95730021d60a0f8d50d14",