Skip to content

Commit d576b65

Browse files
committed
Fix queue processor potentially not finishing processor of in-flight items
1 parent 67c00c0 commit d576b65

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

osu.Server.QueueProcessor/QueueProcessor.cs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -165,6 +165,14 @@ public void Run(CancellationToken cancellation = default)
165165
}
166166

167167
Console.WriteLine("Shutting down..");
168+
169+
while (totalInFlight > 0)
170+
{
171+
Console.WriteLine($"Waiting for remaining {totalInFlight} in-flight items...");
172+
Thread.Sleep(5000);
173+
}
174+
175+
Console.WriteLine("Bye!");
168176
}
169177
}
170178

0 commit comments

Comments
 (0)