对返回值的函数实现超时

Question

我有一个函数可以在串行端口上发出读取或写入请求，然后返回读取的值。我正在使用 Commstudio express （我正在实现 Commstudio 中的一个类），但它的超时功能似乎根本不起作用，所以我正在尝试实现我自己的超时。目前，我有一个根据请求设置的计时器，用于读取或写入端口，如果计时器关闭，回调将关闭连接，从而导致异常。我试图让计时器的回调抛出异常，但是异常需要通过调用原始读/写函数的线程向上传播，所以这样，它可以工作，但我觉得它很混乱，而且有一定是做我想做的事的更好方法。

Answer 1

这是一个通用解决方案，允许您在超时中包装任何方法：

http://kossovsky.net/index.php/2009/07/csharp-how-to-limit-method-execution-time/

它使用有用的 Thread.Join 重载接受以毫秒为单位的超时，而不是手动使用计时器。我唯一要做的不同就是交换成功标志和结果值以匹配 TryParse 模式，如下所示：

public static T Execute<T>(Func<T> func, int timeout)
{
    T result;
    TryExecute(func, timeout, out result);
    return result;
}

public static bool TryExecute<T>(Func<T> func, int timeout, out T result)
{
    var t = default(T);
    var thread = new Thread(() => t = func());
    thread.Start();
    var completed = thread.Join(timeout);
    if (!completed) thread.Abort();
    result = t;
    return completed;
}

这就是您使用它的方式：

var func = new Func<string>(() =>
    {
        Thread.Sleep(200);
        return "success";
    });
string result;
Debug.Assert(!TryExecute(func, 100, out result));
Debug.Assert(result == null);
Debug.Assert(TryExecute(func, 300, out result));
Debug.Assert(result == "success");

您还可以添加接受 操作 而不是 Func 如果你想执行一个不返回值的方法。

Answer 2

听起来你正在执行阻塞读/写操作。您想要做的是非阻塞读/写。

可能有一种方法可以告诉 com 端口您想要非阻塞。

您确定超时不适用于 commstudio 吗？也许你必须做一些特殊的事情来初始化它们。

在任何情况下，您都希望读取尽可能多的数据，如果没有可用的数据，则超时（取决于超时的值是多少）。您需要在没有可用数据且没有错误的情况下继续循环，然后在没有任何可用数据时返回超时条件。

让您的读取函数返回一个整数。负值=错误值，例如-1=超时，读取的正字节数...至少我就是这样做的。

Answer 3

您可以创建一个扩展方法，该方法将 Task 和 T 类型的 defaultValue 作为输入。这是我的实现。

 public static class Helpers
    {
        public static Task<T> SetTimeout<T>(this Task<T> task, T defaultValue, int timeoutInMilliseconds = 1000)
        {
            var timeout = Task.Delay(timeoutInMilliseconds);
            Task.WaitAny(task, timeout);

            if (!task.IsCompleted)
                return Task.FromResult(defaultValue);

            return task;
        }
    }

这是一个用法示例：

var cars = await _myService.GetCars().SetTimeout(new List<string>() { "Toyota", "Nissan" });

Answer 4

对于comport，您可以只测试是否有任何可用的东西，然后进行读取，而不是在不知道还有什么东西的情况下进行阻塞读取。像这样的东西：

Int32 timeout=1000;
String result = String.Empty';
while (timeout!=0) {
  if (Serial.BytesToRead>0) {
    while (Serial.BytesToRead>0) {
      result+=Serial.ReadChar();
    }
    break;
  }
  Thread.Sleep(1);
  timeout--;
}

Answer 5

如果有人想在 VB.Net 中做到这一点，请不要听那些说做不到的人的话！
您可能需要更改通用参数以适合您的用例。

  Public Shared Function Execute(Of I, R)(Func As Func(Of I, R), Input As I, TimeOut As Integer) As R
    Dim Result As R
    TryExecute(Func, Input, TimeOut, Result)
    Return Result
  End Function

  Public Shared Function TryExecute(Of I, R)(Func As Func(Of I, R), Input As I, TimeOut As Integer, ByRef Result As R) As Boolean
    Dim OutParam As R = Nothing
    Dim Thread As New System.Threading.Thread(Sub() InlineAssignHelper(OutParam, Func(Input)))
    Thread.IsBackground = True
    Thread.Start()
    Dim Completed As Boolean = Thread.Join(TimeOut)
    If Not Completed Then Thread.Abort()
    Result = OutParam
    Return Completed
  End Function

  Private Shared Function InlineAssignHelper(Of T)(ByRef Target As T, ByVal Value As T) As T
    Target = Value
    Return Value
  End Function

以及如何使用它的一个示例（我的示例是使用 Regex.Match，如果模式包含太多通配符，有时会出现“never never land”的情况：

  Public Function Match(Input As String) As Match
    If Regex Is Nothing Then Return Nothing
    Dim RegexMatch As System.Text.RegularExpressions.Match = Nothing
    Dim Func As New Func(Of String, System.Text.RegularExpressions.Match)(Function(x As String) Regex.Match(x))
    If Runtime.TryExecute(Of String, System.Text.RegularExpressions.Match)(Func, Input, 2000, RegexMatch) Then
      Return (New Match(Me, Regex.Match(Input), Input))
    Else
      Return Nothing
    End If
  End Function