3

我不是异步操作方面的专家，希望有人能帮我指出问题。

在我的一种方法中，我编写了一个包装器，

public static async Task<int> ExecuteNonQueryRawSQLAsync(string sqlStatement)
{
    int _returnValue = -1;
    using (SqlConnection _conn = new SqlConnection("connectionString"))
    {
        using (SqlCommand _comm = new SqlCommand())
        {
            _comm.Connection = _conn;
            _comm.CommandText = sqlStatement;
            _comm.CommandType = CommandType.Text;

            // other codes on setting parameter

            try
            {
                await _conn.OpenAsync();
                _returnValue = Convert.ToInt32(await _comm.ExecuteNonQueryAsync());
            }
            catch (Exception)
            {
                throw;
            }
        }
    }
    return _returnValue;
}

在我的 UI 中，我调用这样的方法，

int _recordsAffected = await MyClass.ExecuteNonQueryRawSQLAsync("INSERT....");

为了测试它是否真的有效，我尝试在连接字符串中提供一个无效的数据库服务器地址，以便它继续搜索直到它抛出异常。

当程序仍在连接时，UI 冻结。我的包装中缺少什么？还是我需要做任何其他需要的初始化？

4

2 回答 2

5

从痛苦的记忆来看，TCP 套接字有一个非常相似的问题 - 基本上，名称解析是同步执行的，即使对于异步操作也是如此。有两种方法可以解决这个问题：

  • 使用 IP 地址而不是名称
  • 确保你从一个工作线程Open*启动//Connect*任何东西——也许Task.StartNew

未经测试，但大概是：

await Task.StartNew(_conn.Open);
于 2013-10-08T08:33:06.393 回答
0

await "somemethod" 并不意味着该方法被异步调用。您仍在执行常规方法调用，该方法调用将像其他任何方法一样运行，直到被调用的方法决定返回表示异步操作的任务，然后您等待。

如果该方法在返回等待任务之前做了很多耗时的事情，您可以使用TaskFactory.Startnew()调用它。

于 2013-10-08T08:53:46.710 回答