C# と VB.NET の質問掲示板

C# 2005 Express（Framework2.0）で開発しています。
宜しくお願いします。

Tcpで通信するアプリを開発中です。
System.Net.TcpClientの同期式の接続だと
Serverの電源OFFの場合に
２０秒程度待たされます。

そこで、非同期接続を使いタイムアウトを
加味して接続するClassを作成しました。

WaitOneでタイムアウト時に何もしないと
その後ConnectCallBackが走るため
タイムアウトでCloseをやってみました。

特に問題はないと思ってるのですが、
ご意見ありましたら、お願いします。


    public class TcpConnect {
        /// <summary>
        /// 接続待ちEvent
        /// </summary>
        private ManualResetEvent _evConnect = new ManualResetEvent(false);

        /// <summary>
        /// 非同期接続処理のException
        /// </summary>
        private Exception _connEx;

        /// <summary>
        /// 指定先に接続したTcpClient クラスを返す(タイムアウト機能付)
        /// </summary>
        /// <param name="host">DNSマシン名orIPアドレス</param>
        /// <param name="portNo">ポート番号</param>
        /// <param name="timeoutMSec">タイムアウト[mSec]</param>
        /// <returns></returns>
        public TcpClient Connect(string host, int portNo, int timeoutMSec) {

            lock (this) {
                _evConnect.Reset();
                _connEx = null;

                TcpClient tc = new TcpClient();
                tc.BeginConnect(host, portNo, new AsyncCallback(ConnectCallBack), tc);

                if (_evConnect.WaitOne(timeoutMSec, false)) {
                    if (_connEx == null) {
                        return tc;
                    } else {
                        throw _connEx;
                    }
                } else {
                    // ConnectCallBackを発生させる
                    // （TcpClient.Clientがnullで発生する）
                    tc.Close();

                    // タイムアウト通知
                    throw new TimeoutException("Tcp Connect Timeout");
                }
            }
        }

        /// <summary>
        /// TcpClient.BeginConnect の CallBack
        /// </summary>
        /// <param name="ar"></param>
        private void ConnectCallBack(IAsyncResult ar) {

            try {
                TcpClient client = ar.AsyncState as TcpClient;
                if (client.Client != null) {
                    client.EndConnect(ar);
                } else {
                    // BeginConnect中にTcpClient.Close
                    // を呼んだことにより発生
                    // 無視する
                }
            } catch (Exception ex) {
                _connEx = ex;
            } finally {
                _evConnect.Set();
            }
        }
    }

■No6784 (JJ さん) に返信
> 今回のアプリではマルチスレッドで
> 同時にということはないので
> 問題ないかと考えております。

それは問題認識が甘いです。
BeginConnectした時点でマルチスレッドです。
Callbackはどんなスレッドで呼ばれるのか、保証がありません。
呼び出し元の場合もあれば、Pooledなスレッドの場合、そうでない他のスレッドの場合もあります。
ですので、Callbackで変数を使うなら、同期機構をいれないとダメです。

> 具体例をあげていただけると大変助かります。

何をしたいのかも明確にわかるので、
私の持ってるソースを見せれば役に立つだろうと思うのですが。
今日はいろいろめんどくさいので、手書き+検証無し+うろ覚えで。

まず、ウェイトだけならCallbackは要りません。
IAsyncResult.AsyncWaitHandleで待てばいいだけです。
AsyncWaitHandleは作成にコストがかかる場合もあるので、
IsCompleteかCompletedSynchronouslyで確認しておくといいです。
BeginXXXを途中で無理やり閉じると例外を吐くものもあるのでそれも処理します。

まとめると。
BeginXXXの一般的タイムアウト指定方法は下記の用になります。

(手書き+検証無し+うろ覚えにつき注意)
IAsyncResult iar = tc.BeginConnect(host, portNo, null, null);
if ( !iar.CompletedSynchronously ) { か if ( !iar.IsCompleted ) {
  if ( !iar.WaitOne(timeoutMSec, false) ) {
    try {
      //ここにCleanupを。
      tc.close();
    } catch {
    }
    Throw New TimeoutException();
  }
}
tc.EndConnect(iar);

IAsyncResultに関しては「非同期プログラミングのデザインパターン」で検索。
IAsyncResultをきちんと理解しておくと、かなり使えます。

■No6786 (れい さん) に返信

認識の甘さを痛感しています。
ご指摘ありがとうございます。

ここまでシンプルに出来るとは。。。
本当に問題も無駄もありますね。


ひとつ疑問があります。

> if ( !iar.CompletedSynchronously ) { か if ( !iar.IsCompleted ) {

この部分の必要性がわかりません。
無条件にやってもWaitOneはシグナル状態で
すぐに抜けるのではないでしょうか？

度々申し訳ありませんが、ご教授いただけると幸いです。