.NETを使用するサーバの基本アルゴリズムはではありません。 'クライアントごとのスレッド'に基づいていますか？クライアントごとのスレッドではないコードを作成する
編集私は、サーバーが使用している一般的なプロセスを説明する基本的な3、4多分5行のアルゴリズム/ psuedocode /パターンを探しています。これとは逆
何か：
open a server socket // this uses the port the clients know about
while(running)
client_socket = server_socket.listen
fork(new handler_object(client_socket))
スレッドプールは、サーバがクライアントよりも少ないスレッドを持つことができるようになります。
だから、アルゴリズムはスレッドプールを使用するでしょうが、どのようなコンテキストでですか？使用される基本的なアルゴリズムは何ですか？ psuedocodeの3,4,5行を探しているだけです。 –
イベントループ。ソケットが書き込み可能になるのを待ち、書き込みを待つ、接続を待つ、受け入れるなど。このアプローチは、通常はクライアントの状態を追跡するためにクロージャ以上のものを必要としないので、ほとんどの場合スレッドよりも拡張性があります。
広範で一般的なもの（つまり、ネットや他のプラットフォームに固有のものではない）では、サービスはプログラムされています2つの方法のいずれか、または両方の組み合わせで
接続ごとのスレッド：注意しておきますが、これはカーネルスレッドやプロセスなどの単一のスケジューリングエンティティ、あるいはユーザー空間でプラットフォームによって実装された軽いスレッドまたはコルーチンを使用します。単一の要求を処理することに順調に関わっています。
例の擬似コード：上記のサンプルの
function run(connection)
while(connection is open)
frobnicate(connection)
function main
listener = new Listener(port)
threads = new Collection<Thread>()
while(running)
connection = listener.accept()
threads.add(new Thread(run, connection))
join(threads)
exit()
重要な機能：
ノンブロッキング：1つの実行スレッドが複数の接続を管理し、特定の接続がストールしたとき、データがネットワークを介して移動するのを待っているとき、またはディスクから読み込むときにプロセスがスキップするそれ以上の接続で動作します。
例の擬似コード：このスニペットの
function main
connections = new Collection<Connection>()
listener = new Listener()
connections.append(listener)
foreach connection in connections:
if connection.ready():
if connection is listener:
connections.add(connection.accept())
else:
if connection is open:
nb_frobnicate(connection)
else:
connections.remove(connection)
yield()
if(not running)
exit()
特徴：マルチスレッド・バージョンで
frobnicateがブロックされていると、災害になります。たとえ1つの接続が準備できなくなっても、他の接続は作業を行うことができます。 これに対処するには、接続で非ブロック操作を使用するように注意している代替機能が使用されます。これらの読み取りと書き込みはすぐに戻ります。 呼び出し側にどれくらいの作業を実行できるかを示す値が返されます。その場合、 がまったく動作しない場合、プログラムは接続がより多くの作業の準備ができていることを知っているので、ただちに としてもう一度試す必要があります。私は nb_frobnicateに名前を変更して、この機能がノンブロッキングであることを注意していることを示しています。select()または poll()のいずれかと呼ばれます（どちらも利用可能です）。それでも、私は 以上のネットワーク接続で作業したいかもしれないので、この方法で表示することにしました。私が知る限り、 は、すべての可能なブロック操作を総称的に待つことはできません。 ディスクIO（Windowsのみ）、タイマー、ハードウェア割り込み（画面の更新など）を待つ必要がある場合は する必要がありますさまざまなイベントソースを手動でポーリングします。yield()関数です。この関数は、IO割り込み が発生するまでスリープします。これは、IOが処理される準備ができていない場合に必要です。これを行わなかった場合、 プログラムはビジー待機し、各ポートをチェックして再確認し、 にはデータが準備されていないことがわかり、不必要にCPUを浪費します。プログラムが ネットワークIO（またはPOSIXシステム上のディスク）で待機する必要がある場合は、 ブロッキングモードでselect/pollを呼び出すことができ、ネットワーク接続が可能になるまでスリープします。しかし、もっと多くの種類のイベントを待つ場合は のノンブロッキングバージョンを使用し、他のイベントソースをそのイディオムに従ってポーリングしてから、 がすべてブロックするようにしなければなりません。frobnicate()機能のコストではないため、これはほとんど問題ではありません。前述したように、これらを組み合わせて使用することで、マルチコアシステムでのCPU使用率の向上などの複数のスケジューリングエンティティの利点の多く、コンテクストの切り替えが少なくなるため負荷が軽減されます。この
例：このプログラムに関する
function worker(queue)
connections = Collection<Connection>()
while(running)
while(queue not empty)
connections.add(queue.pop)
foreach connection in select(connections)
if connection is open:
nb_frobnicate(connection)
else:
connections.remove(connection)
function main
pool = new Collection<Thread, Queue<Connection> >()
for index in num_cpus:
pool[index] = new Thread(worker), new Queue<Connection>
listener = new Listener(port)
while(running)
connection = listener.accept()
selected_thread = 0
for index in pool.length:
if pool[index].load() < pool[selected_thread].load()
selected_thread = index
pool[selected_thread].push(connection)
pool[selected_thread].wake()
ノート：
Queue<Connection>を使用して行われます。select()を使用しているため、準備完了の空のリストが返され、スレッドはもう一度そのキューを空にできます。編集：追加のサンプルコード：
これは意味があります。したがって、非ブロッキング接続は、オブジェクトを管理するスレッドのほうに向いています。ノンブロッキング方式の一般的なアルゴリズムはありますか？ –
処理が必要であるものは何でもやって、準備ができていたソケット（クライアント）を決定するために、Selectを呼び出し、その後、読み出し及び/又はそれらのソケットに書き込むループときにないソケット準備が整いました。
擬似コード：
loop {
to_read.add(client1);
to_read.add(client2);
select(to_read, timeout = 0.5);
for client in to_read { // to_read is modified by select
data = client.read
handle(data)
}
if to_read is empty {
do_bookeeping()
}
}
有望そうです。選択を使用するには、一般的なアルゴリズム/擬似コード/パターンがありますか？ –
素晴らしい！ありがとうございました！ –
あなたは、スレッドプールによって制限され、要求ごとにスレッドを行うことができます。しかし、これを処理するための非同期メソッドに興味があるかもしれません。このページでは、アプローチがどのように動作するか非同期の良い仕事をしていません：
例えば、イベント・キューとスレッドプールを使用します：また
when [something happens] then
[create an event for something]
[put it in the queue]
： - >コールバックAuthenticatedStreamで
while [something in queue]
if [thread is available] then
remove [thing] from queue
run [thing-response] on [available thread]
else [wait a little while]
このアーキテクチャは
興味深い。どのようにソケットにそれを適用するのだろうか？ –
@ [不明]： "接続要求" = [何か起こる]、queue.Add（新しいMyEvent（MyEnum.ConnectionRequested、connectionInfo））=イベントを作成し、キューに入れます。イベントタイプへの応答は、（connectionInfoを介して）資格をチェックしたり、接続を確立したりすることです。新しい接続は追加イベントのソースになる可能性があります[別の回答のソケットリストポーリングを参照] –
ありがとうSteven。 –
Socket.BeginAccept非常にスケーラブルです。 BeginAuthenticateAsServer - >コールバックストリーム。 BeginRead - >コールバックで新しいBeginRead、処理要求、ストリームをポストします。回答はBeginWriteです。
あなたが本当にそれを必要としない場合は、認証されたストリームの一部（SSLまたはKerberos/NTLM）を取り出すことができ、それは次のようになります。 Socket.BeginAccept - >コールバックソケットインチBeginReceive - >コールバックで新しいBeginReceiveをポストし、リクエストを処理してからソケットを追加します。回答はBeginWriteです。
を要約してくださいアルゴリズムが使用されていますか？ –
典型的なイベント駆動型アプリケーション（イベントはソケット受け入れ、読み取り完了、書き込み完了）。スタックベースのクライアント状態（スレッド）の代わりに、ヒープベースのクライアント状態（つまり、接続/状態を表すオブジェクト）があります。 –
イアン・グリフィスは、クライアントごとにスレッドを使用することなく、複数のクライアントを処理するexcellent (.NET) introductionを持っています。
それは素晴らしい記事です。どうもありがとうございます！ –
あなたは何を達成しようとしていますか？ 「クライアントごとのスレッド」のどの側面を避けたいですか？ –