使用 AsyncCallback 委托结束异步操作

在等待异步操作结果的同时可以进行其他工作的应用程序不应在操作完成之前阻止等待。可以使用下列方法之一来在等待异步操作完成的同时继续执行指令。

可使用 AsyncCallback 委托来处理另一个线程中的异步操作的结果。本主题中演示了此方法。

可使用异步操作的 BeginOperationName 方法返回的 IAsyncResult 的 IsCompleted 属性来确定此操作是否已完成。有关演示此方法的示例，请参见轮询异步操作的状态。

示例
下面的代码示例演示如何使用 Dns 类中的异步方法来检索用户指定的计算机的域名系统 (DNS) 信息。此示例创建了引用 ProcessDnsInformation 方法的 AsyncCallback 委托。对各个针对 DNS 信息发出的异步请求，将分别调用一次此方法。
请注意，用户指定的主机被传递给了 BeginGetHostByNameObject 参数。有关演示如何定义和使用更复杂的状态对象的示例，请参见使用 AsyncCallback 委托和状态对象。

/*

The following example demonstrates using asynchronous methods to

get Domain Name System information for the specified host computers.

This example uses a delegate to obtain the results of each asynchronous

operation.

*/

using System;

using System.Net;

using System.Net.Sockets;

using System.Threading;

using System.Collections.Specialized;

using System.Collections;

namespace Examples.AdvancedProgramming.AsynchronousOperations

{

public class UseDelegateForAsyncCallback

{

static int requestCounter;

static ArrayList hostData = new ArrayList();

static StringCollection hostNames = new StringCollection();

static void UpdateUserInterface()

{

// Print a message to indicate that the application

// is still working on the remaining requests.

Console.WriteLine("{0} requests remaining.", requestCounter);

}

public static void Main()

{

// Create the delegate that will process the results of the

// asynchronous request.

AsyncCallback callBack = new AsyncCallback(ProcessDnsInformation);

string host;

do

{

Console.Write(" Enter the name of a host computer or <enter> to finish: ");

host = Console.ReadLine();

if (host.Length > 0)

{

// Increment the request counter in a thread safe manner.

Interlocked.Increment(ref requestCounter);

// Start the asynchronous request for DNS information.

Dns.BeginGetHostEntry(host, callBack, host);

}

} while (host.Length > 0);

// The user has entered all of the host names for lookup.

// Now wait until the threads complete.

while (requestCounter > 0)

{

UpdateUserInterface();

}

// Display the results.

for (int i = 0; i< hostNames.Count; i++)

{

object data = hostData [i];

string message = data as string;

// A SocketException was thrown.

if (message != null)

{

Console.WriteLine("Request for {0} returned message: {1}",

hostNames[i], message);

continue;

}

// Get the results.

IPHostEntry h = (IPHostEntry) data;

string[] aliases = h.Aliases;

IPAddress[] addresses = h.AddressList;

if (aliases.Length > 0)

{

Console.WriteLine("Aliases for {0}", hostNames[i]);

for (int j = 0; j < aliases.Length; j++)

{

Console.WriteLine("{0}", aliases[j]);

}

}

if (addresses.Length > 0)

{

Console.WriteLine("Addresses for {0}", hostNames[i]);

for (int k = 0; k < addresses.Length; k++)

{

Console.WriteLine("{0}",addresses[k].ToString());

}

}

}

}

// The following method is called when each asynchronous operation completes.

static void ProcessDnsInformation(IAsyncResult result)

{

string hostName = (string) result.AsyncState;

hostNames.Add(hostName);

try

{

// Get the results.

IPHostEntry host = Dns.EndGetHostEntry(result);

hostData.Add(host);

}

// Store the exception message.

catch (SocketException e)

{

hostData.Add(e.Message);

}

finally

{

// Decrement the request counter in a thread-safe manner.

Interlocked.Decrement(ref requestCounter);

}

}

}

}

Inserted from <http://msdn.microsoft.com/zh-cn/library/ms228972(VS.80).aspx>