SurferOnWww様 HttpHandlerについて検証してみました。
>ASP.NET の非同期プログラミングを使ったスケール変換可能なアプリケーション
>http://msdn.microsoft.com/ja-jp/magazine/cc163463.aspx
上記サンプルは、データベースが準備できない都合上自分で同様のコードを作ってみました。
ASP.NETスレッドプールに影響があるかどうか、下記コードで検証を行ってみました。
machine.configを以下のように変更して、影響がわかりやすいようにして確認しました。
<processModel maxWorkerThreads = "1">
結果
・IHttpHandler
Thread・・・ASP.NETのスレッドプールを利用しない。
ThreadPool・・・ASP.NETと同じスレッドプールを利用するようです。
・IHttpAsyncHandler
Thread・・・ASP.NETのスレッドプールを利用しない。
ThreadPool・・・ASP.NETと同じスレッドプールを利用するようです。
※IHｔｔｐAsyncHandlerについては、サーバー内での非同期処理を待つようなしくみのようで、私の意図するところとは違うようです。
ASP.NET用のスレッドプールと、その他スレッドプールというものが存在するのかどうかわかりませんが、ThreadPoolを利用すると、サーバー全体のスループットに影響がありそうです。なので今回はThreadを利用しようかと思います。
また、Threadを利用した場合も、ThreadPoolを利用した場合にもはやり、 HttpContext.Current は引き継がれないようです。
クライアントに処理が戻った後もHttpContextを使い続けるのはよくない気がしております。これについてどなたか情報をお持ちではないでしょうか？
根本的な解決には、まずシステムのデザインを再検討したほうがよさそうな気がしております。
---------------------------------------------------------------------
検証に利用した同期ＨｔｔｐＨａｎｄｌｅｒコード
//#define THREAD
//#define THREADPOOL
#define DELEGATE
using System;
using System.Collections.Generic;
using System.Text;
using System.Web;
using System.Threading;
namespace TestHandlerNameSpace
{
public class TestHandler1 : IHttpHandler
{
#region IHttpHandler メンバ
public bool IsReusable
{
get { return false; }
}
public void ProcessRequest(HttpContext context)
{
//■10秒待機してASP.NETスレッドプールを浪費→キューが小さくて要求が多いとエラーになる。キューを大きくすると問題ない
//Thread.Sleep(10000);//10秒まち。
#if THREAD
//■スレッドを作って10秒まち→何事もなかったかのように戻る。HttpContextは引き継がれない
Thread thread = new Thread((ParameterizedThreadStart)delegate(object param)
{
Thread.Sleep(10000);
});
thread.Start(null);
#endif
#if THREADPOOL
//■スレッドプールを作って10秒まち→要求と同一コンテキストで待つのと同じ遅延が発生する。HttpContextは引き継がれない
ThreadPool.QueueUserWorkItem((WaitCallback)delegate(object obj)
{
Thread.Sleep(10000);
}, null);
#endif
#if DELEGATE
//■一応デリゲートでも試す。→スレッドプールで待つよりも処理は早い。HttpContextは引き継がれない
ThreadStart start = (ThreadStart)delegate(){
HttpApplication a = new HttpApplication();
Thread.Sleep(10000);
};
start.BeginInvoke((AsyncCallback)delegate(IAsyncResult iar)
{
ThreadStart s = iar.AsyncState as ThreadStart;
s.EndInvoke(iar);
}, start);
#endif
}
#endregion
}
}
検証に利用した非同期ＨｔｔｐＨａｎｄｌｅｒコード
//#define THREAD
//#define THREADPOOL
#define DELEGATE
using System;
using System.Collections.Generic;
using System.Text;
using System.Web;
using System.Threading;
using System.Collections;
namespace TestHandlerNameSpace
{
public class TestHandler2 : IHttpAsyncHandler
{
#region IHttpAsyncHandler メンバ
public IAsyncResult BeginProcessRequest(HttpContext context, AsyncCallback cb, object extraData)
{
AsynchOperation asynch = new AsynchOperation(cb, context, extraData);
asynch.StartAsyncWork();
return asynch;
}
public void EndProcessRequest(IAsyncResult result)
{
}
#endregion
#region IHttpHandler メンバ
public bool IsReusable
{
get { return false; }
}
public void ProcessRequest(HttpContext context)
{
throw new Exception("The method or operation is not implemented.");
}
#endregion
class AsynchOperation : IAsyncResult
{
private bool _completed;
private Object _state;
private AsyncCallback _callback;
private HttpContext _context;
bool IAsyncResult.IsCompleted { get { return _completed; } }
WaitHandle IAsyncResult.AsyncWaitHandle { get { return null; } }
Object IAsyncResult.AsyncState { get { return _state; } }
bool IAsyncResult.CompletedSynchronously { get { return false; } }
public AsynchOperation(AsyncCallback callback, HttpContext context, Object state)
{
_callback = callback;
_context = context;
_state = state;
_completed = false;
}
public void StartAsyncWork()
{
//■10秒待機してASP.NETスレッドプールを浪費→キューが小さくて要求が多いとエラーになる。キューを大きくすると問題ない
//Thread.Sleep(10000);//10秒まち。
#if THREAD
//■スレッドを作って10秒まち→何事もなかったかのように戻る。HttpContextは引き継がれない
Thread thread = new Thread((ParameterizedThreadStart)StartAsyncTask);
thread.Start(null);
#endif
#if THREADPOOL
//■スレッドプールを作って10秒まち→要求と同一コンテキストで待つのと同じ遅延が発生する。HttpContextは引き継がれない
ThreadPool.QueueUserWorkItem((WaitCallback)StartAsyncTask, null);
#endif
#if DELEGATE
//■一応デリゲートでも試す。→スレッドプールで待つよりも処理は早い。HttpContextは引き継がれない
ParameterizedThreadStart start = (ParameterizedThreadStart)StartAsyncTask;
start.BeginInvoke(null, null, start);
#endif
//ThreadPool.QueueUserWorkItem(new WaitCallback(StartAsyncTask), null);
}
private void StartAsyncTask(Object workItemState)
{
Thread.Sleep(10000);
_completed = true;
_callback(this);
}
}
}
}
