You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
77 lines
1.4 KiB
77 lines
1.4 KiB
2 years ago
|
/*---------------------------------------------------------------------------------------------
|
||
|
* Copyright (c) Unity Technologies.
|
||
|
* Copyright (c) Microsoft Corporation. All rights reserved.
|
||
|
* Licensed under the MIT License. See License.txt in the project root for license information.
|
||
|
*--------------------------------------------------------------------------------------------*/
|
||
|
using System;
|
||
|
using System.Threading;
|
||
|
|
||
|
namespace Microsoft.Unity.VisualStudio.Editor
|
||
|
{
|
||
|
internal class AsyncOperation<T>
|
||
|
{
|
||
|
private readonly Func<T> _producer;
|
||
|
private readonly ManualResetEventSlim _resetEvent;
|
||
|
|
||
|
private T _result;
|
||
|
private Exception _exception;
|
||
|
|
||
|
private AsyncOperation(Func<T> producer)
|
||
|
{
|
||
|
_producer = producer;
|
||
|
_resetEvent = new ManualResetEventSlim(initialState: false);
|
||
|
}
|
||
|
|
||
|
public static AsyncOperation<T> Run(Func<T> producer)
|
||
|
{
|
||
|
var task = new AsyncOperation<T>(producer);
|
||
|
task.Run();
|
||
|
return task;
|
||
|
}
|
||
|
|
||
|
private void Run()
|
||
|
{
|
||
|
ThreadPool.QueueUserWorkItem(_ =>
|
||
|
{
|
||
|
try
|
||
|
{
|
||
|
_result = _producer();
|
||
|
}
|
||
|
catch (Exception e)
|
||
|
{
|
||
|
_exception = e;
|
||
|
}
|
||
|
finally
|
||
|
{
|
||
|
_resetEvent.Set();
|
||
|
}
|
||
|
});
|
||
|
}
|
||
|
|
||
|
private void CheckCompletion()
|
||
|
{
|
||
|
if (!_resetEvent.IsSet)
|
||
|
_resetEvent.Wait();
|
||
|
}
|
||
|
|
||
|
|
||
|
public T Result
|
||
|
{
|
||
|
get
|
||
|
{
|
||
|
CheckCompletion();
|
||
|
return _result;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
public Exception Exception
|
||
|
{
|
||
|
get
|
||
|
{
|
||
|
CheckCompletion();
|
||
|
return _exception;
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
}
|