Listing 1: An implementation of IAsynchResult

public interface IAsyncResult
{
object AsyncState { get; }
WaitHandle AsyncWaitHandle { get; }
bool CompletedSynchronously { get; }
bool IsCompleted { get; }
}
¬ public class AsynchResult<TArg, TResult> : IAsyncResult
{
private readonly AsyncCallback m_asynchCallBack;
private readonly Object m_asychState;
private int m_completedState;
private ManualResetEvent m_asynchWaitHandle;
private Exception m_exception;
private TResult m_result = default(TResult);
private TArg m_arg = default(TArg);

public TArg Arg { get { return m_arg; } }

public AsynchResult(TArg arg, AsyncCallback callback, Object state)
{
m_arg = arg;
m_asynchCallBack = callback;
m_asychState = state;
}

public void SetAsCompleted(TResult result, bool completedSynchronously, Exception exception)
{
m_result = result;
m_exception = exception;

int previous = Interlocked.Exchange(ref m_completedState,
completedSynchronously ? (int) AsynchronousState.CompletedSychronously : (int) AsynchronousState.
CompletedAsynchronously);

if (previous != (int)AsynchronousState.Pending)
{
throw new InvalidOperationException("A result has already been set");
}

if (m_asynchWaitHandle != null)
{
m_asynchWaitHandle.Set();
}

if (m_asynchCallBack != null)
{
m_asynchCallBack(this);
}
}

public TResult EndInvoke()
{
if (!IsCompleted)
{
AsyncWaitHandle.WaitOne();
AsyncWaitHandle.Close();
m_asynchWaitHandle = null;
}

if (m_exception != null)
{
throw m_exception;
}

return m_result;
}

#region IAsyncResult Members

public object AsyncState
{
get
{
return m_asychState;
}
}

public System.Threading.WaitHandle AsyncWaitHandle
{
get
{
if (m_asynchWaitHandle == null)
{
bool done = IsCompleted;
ManualResetEvent resetEvent = new ManualResetEvent(done);

if (Interlocked.CompareExchange(ref m_asynchWaitHandle, resetEvent, null)
!= null)
{
resetEvent.Close();
}
else
{
if (!done && IsCompleted)
{
m_asynchWaitHandle.Set();
}
}
}

return m_asynchWaitHandle;
}
}

public bool CompletedSynchronously
{
get
{
return Thread.VolatileRead(ref m_completedState) == (int)AsynchronousState.CompletedSychronously;
}
}

public bool IsCompleted
{
get { return Thread.VolatileRead(ref m_completedState) != (int)AsynchronousState.Pending; }
}

#endregion
}

About the Author

Eric Vogel is a Senior Software Developer for Red Cedar Solutions Group in Okemos, Michigan. He is the president of the Greater Lansing User Group for .NET. Eric enjoys learning about software architecture and craftsmanship, and is always looking for ways to create more robust and testable applications. Contact him at [email protected].

comments powered by Disqus

Featured

  • Microsoft's Tools to Fight Solorigate Attack Are Now Open Source

    Microsoft open sourced homegrown tools it used to check its systems for code related to the recent massive breach of supply chains that the company has named Solorigate.

  • Microsoft's Lander on Blazor Desktop: 'I Don't See a Grand Unified App Model in the Future'

    For all of the talk of unifying the disparate ecosystem of Microsoft-centric developer tooling -- using one framework for apps of all types on all platforms -- Blazor Desktop is not the answer. There isn't one.

  • Firm Automates Legacy Web Forms-to-ASP.NET Core Conversions

    Migration technology uses the Angular web framework and Progress Kendo UI user interface elements to convert ASP.NET Web Forms client code to HTML and CSS, with application business logic converted automatically to ASP.NET Core.

  • New TypeScript 4.2 Tweaks Include Project Explainer

    Microsoft shipped TypeScript 4.2 -- the regular quarterly update to the open source programming language that improves JavaScript with static types -- with a host of tweaks including a way to explain why files are included in a project.

Upcoming Events