4

限られた時間内にメソッドが完了しなかった場合、メソッドの実行を停止する必要があります。

この作業を行うには、次のThread.Abort方法でメソッドを使用できます。

void RunWithTimeout(ThreadStart entryPoint, int timeout)
{
    var thread = new Thread(() =>
    {
        try
        {
            entryPoint();
        }
        catch (ThreadAbortException)
        {   }

    }) { IsBackground = true };

    thread.Start();

    if (!thread.Join(timeout))
        thread.Abort();
}

私が .NET 3.5 を使用していることを考えると、より良い方法はありますか?

編集: ここのコメントに従ってください my entryPoint, しかし、私は any の良い方法を探していますentryPoint.

void entryPoint()
{
   // I can't use ReceiveTimeout property
   // there is not a ReceiveTimeout for the Compact Framework
   socket.Receive(...);
}
4

2 に答える 2

9

答えは「作品」によって異なります。作業が安全に停止できるものである場合 (つまり、I/O ブロッキング操作ではない場合) - を使用します。Backgroundworker.CancelAsync(...)

あなたが一生懸命カットしなければならない場合 - 私は を使用することを検討します.Processその場合、Abortingプロセスはよりクリーンです - そしてprocess.WaitForExit(timeout)あなたの友達です.

推奨される TPL は優れていますが、残念ながら .Net 3.5 には存在しません。

編集: Reactive Extensionsを使用して、Jan de Vaan の提案に従うことができます。

これが私の「アクションタイムアウト」の切り取りです-主に他の人がコメントするためにここにあります：

    public static bool WaitforExit(this Action act, int timeout)
    {
        var cts = new CancellationTokenSource();
        var task = Task.Factory.StartNew(act, cts.Token);
        if (Task.WaitAny(new[] { task }, TimeSpan.FromMilliseconds(timeout)) < 0)
        { // timeout
            cts.Cancel();
            return false;
        }
        else if (task.Exception != null)
        { // exception
            cts.Cancel();
            throw task.Exception;
        }
        return true;
    }

編集:明らかに、これはまさにOPが望んでいたものではありません。「キャンセル可能な」ソケットレシーバーを考案する私の試みは次のとおりです。

public static class Ext
{
    public static object RunWithTimeout<T>(Func<T,object> act, int timeout, T obj) where T : IDisposable
    {
        object result = null;
        Thread thread = new Thread(() => { 
            try { result = act(obj); }
            catch {}    // this is where we end after timeout...
        });

        thread.Start();
        if (!thread.Join(timeout))
        {
            obj.Dispose();
            thread.Join();
        }
        return result;
    }       
}

class Test
{
    public void SocketTimeout(int timeout)
    {
        using (var sock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp))
        {
            Object res = Ext.RunWithTimeout(EntryPoint, timeout, sock);
        }
    }

    private object EntryPoint(Socket sock)
    {
        var buf = new byte[256];
        sock.Receive(buf);
        return buf;
    }
}
于 2012-11-07T23:16:31.103 に答える
4

通常、Thread.Abort は不適切なソリューションです。操作がキャンセルされたかどうかを示すフラグを使用し、entryPoint 関数内で確認する必要があります。

 class Program
    {
        static void Main(string[] args)
        {
            RunWithTimeout((token) =>
                               {
                                   Thread.Sleep(2000);
                                   if (token.Cancel)
                                   {
                                       Console.WriteLine("Canceled");
                                   }
                               }, 1000);

            Console.ReadLine();
        }

        private class Token
        {
            public bool Cancel { get; set; }
        }

        static void RunWithTimeout(Action<Token> entryPoint, int timeout)
        {

            Token token = new Token();

            var thread = new Thread(() => entryPoint(token)) { IsBackground = true };

            thread.Start();

            if (!thread.Join(timeout))
                token.Cancel = true;
        }
    }
于 2012-11-07T23:01:06.867 に答える