Skip to content

Commit d062af7

Browse files
committed
final adjustments
1 parent 62f29c1 commit d062af7

File tree

3 files changed

+8
-13
lines changed

3 files changed

+8
-13
lines changed

src/PSParallelPipeline/PoolSettings.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
namespace PSParallelPipeline;
44

5-
internal class PoolSettings(
5+
internal sealed class PoolSettings(
66
int maxRunspaces,
77
bool useNewRunspace,
88
InitialSessionState initialSessionState)

src/PSParallelPipeline/TaskSettings.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
namespace PSParallelPipeline;
44

5-
internal class TaskSettings(
5+
internal sealed class TaskSettings(
66
string script,
77
Dictionary<string, object?> usingStatements)
88
{

src/PSParallelPipeline/Worker.cs

Lines changed: 6 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,12 @@ private async Task Start()
5555
{
5656
if (tasks.Count == tasks.Capacity)
5757
{
58-
await ProcessAnyAsync(tasks).ConfigureAwait(false);
58+
Task task = await Task
59+
.WhenAny(tasks)
60+
.ConfigureAwait(false);
61+
62+
tasks.Remove(task);
63+
await task.ConfigureAwait(false);
5964
}
6065

6166
tasks.Add(PSTask
@@ -75,16 +80,6 @@ await Task
7580
}
7681
}
7782

78-
private static async Task ProcessAnyAsync(List<Task> tasks)
79-
{
80-
Task task = await Task
81-
.WhenAny(tasks)
82-
.ConfigureAwait(false);
83-
84-
tasks.Remove(task);
85-
await task.ConfigureAwait(false);
86-
}
87-
8883
public void Dispose()
8984
{
9085
_pool.Dispose();

0 commit comments

Comments
 (0)