Mam ten fragment kodu, aby asynchronicznego żądania HTTP:Zadanie fromAsync Timeout
public static void MakeRequest(Uri uri, Action<RequestCallbackState> responseCallback)
{
WebRequest request = WebRequest.Create(uri);
request.Proxy = null;
Task.Factory.FromAsync<WebResponse>(request.BeginGetResponse, request.EndGetResponse, null).ContinueWith(task =>
{
WebResponse response = task.Result;
Stream responseStream = response.GetResponseStream();
responseCallback(new RequestCallbackState(response.GetResponseStream()));
responseStream.Close();
response.Close();
});
}
to działa, ale muszę ustawić limit czasu żądania się. Próbowałem użyć request.Timeout, ale nic nie robię. Czy istnieje sposób na ustawienie limitu czasu zadania w tym kodzie?
Edytowane w celu dodania nowego wywołania zwrotnego z limitem czasu. Nowy kod:
public static void MakeRequest(Uri uri, Action<RequestCallbackState> responseCallback)
{
WebRequest request = WebRequest.Create(uri);
request.Proxy = null;
IAsyncResult t = Task.Factory.FromAsync<WebResponse>(request.BeginGetResponse, request.EndGetResponse, null).ContinueWith(task =>
{
WebResponse response = task.Result;
Stream responseStream = response.GetResponseStream();
responseCallback(new RequestCallbackState(response.GetResponseStream()));
responseStream.Close();
response.Close();
});
ThreadPool.RegisterWaitForSingleObject(t.AsyncWaitHandle, new WaitOrTimerCallback(TimeoutCallback), request, 1000, true);
}
private static void TimeoutCallback(object state, bool timedOut)
{
if (timedOut)
{
Console.WriteLine("Timeout");
WebRequest request = (WebRequest)state;
if (state != null)
{
request.Abort();
}
}
}
Testowanie z:
HttpSocket.MakeRequest(new Uri("http://www.google.comhklhlñ"), callbackState =>
{
if (callbackState.Exception != null)
throw callbackState.Exception;
Console.WriteLine(GetResponseText(callbackState.ResponseStream));
});
Thread.Sleep(10000);
Zmieniłem kod, jak widać w pytaniu, ale limit czasu nie działa. Otrzymuję tylko wywołanie zwrotne z timedOut false, a po tym czasie nic się nie dzieje. –
@David: Wprowadziłem trochę działającego kodu ... –
Nie mogę sprawić, żeby działało. Mam wątek.sleep w głównej metody. Czy to może być problem? Zaktualizowałem wpis, aby pokazać kod, którego używam do przetestowania go. –