mirror of
https://github.com/chylex/Minecraft-Phantom-Panel.git
synced 2025-08-16 12:31:43 +02:00
.config
.run
.workdir
Agent
Common
Docker
Server
Utils
Phantom.Utils.Collections
Phantom.Utils.Collections.Tests
Phantom.Utils.Cryptography
Phantom.Utils.Events
Phantom.Utils.IO
Phantom.Utils.Rpc
Phantom.Utils.Runtime
AssemblyAttributes.cs
CancellableBackgroundTask.cs
CancellableSemaphore.cs
EnvironmentVariables.cs
OneShotProcess.cs
Phantom.Utils.Runtime.csproj
PosixSignals.cs
Process.cs
ProcessConfigurator.cs
StopProcedureException.cs
TaskManager.cs
Tasks.cs
WaitHandleExtensions.cs
Phantom.Utils.Runtime.Tests
.dockerignore
.gitattributes
.gitignore
AddMigration.bat
AddMigration.sh
Directory.Build.props
Directory.Build.targets
Dockerfile
LICENSE
Packages.props
PhantomPanel.sln
README.md
global.json
28 lines
873 B
C#
28 lines
873 B
C#
namespace Phantom.Utils.Runtime;
|
|
|
|
public static class WaitHandleExtensions {
|
|
public static Task WaitOneAsync(this WaitHandle waitHandle, CancellationToken cancellationToken = default) {
|
|
var taskCompletionSource = new TaskCompletionSource();
|
|
|
|
void SetResult(object? state, bool timedOut) {
|
|
taskCompletionSource.TrySetResult();
|
|
}
|
|
|
|
void SetCancelled() {
|
|
taskCompletionSource.TrySetCanceled(cancellationToken);
|
|
}
|
|
|
|
var waitRegistration = ThreadPool.RegisterWaitForSingleObject(waitHandle, SetResult, null, Timeout.InfiniteTimeSpan, true);
|
|
var tokenRegistration = cancellationToken.Register(SetCancelled, useSynchronizationContext: false);
|
|
|
|
void Cleanup(Task t) {
|
|
waitRegistration.Unregister(null);
|
|
tokenRegistration.Dispose();
|
|
}
|
|
|
|
var task = taskCompletionSource.Task;
|
|
task.ContinueWith(Cleanup, CancellationToken.None);
|
|
return task;
|
|
}
|
|
}
|