Блог

Я хочу полностью понять, как реализовать ключевые слова async и await в TAP. Я наткнулся на эту запись в MSDN: https://learn.microsoft.com/en-us/dotnet/csharp/async

В этом сообщении вы можете прочитать следующие два утверждения:

Для кода, связанного с вводом-выводом, вы ожидаете операции, которая возвращает задачу или задачу внутри асинхронного метода.

Вот два вопроса, которые вы должны задать, прежде чем писать какой-либо код:

Будет ли ваш код «ждать» чего-то, например, данных из базы данных?

Если ваш ответ «да», то ваша работа связана с вводом / выводом.

Будет ли ваш код выполнять дорогостоящие вычисления?

Если вы ответили «да», то ваша работа связана с процессором.

Если ваша работа связана с вводом / выводом, используйте async и ожидайте без Task.Run. Вы не должны использовать библиотеку параллельных задач. Причина этого подробно изложена в Async .

Связанная статья https://learn.microsoft.com/en-us/dotnet/standard/async-in-depth

Но я не понимаю, почему я не должен использовать Task.Запуск для извлечения данных из базы данных.

Я имею в виду, что для большинства методов я могу просто использовать часть счетчика асинхронности, такую как ExecuteNonQueryAsync или ExecuteScalarAsync

Но как я должен использовать адаптер данных для извлечения данных. Рассмотрим следующий метод

 public DataTable SelectData(string selectCommand)
{
    OpenConnection();
    DataTable data = new DataTable();
    Command.CommandType = CommandType.Text;
    Command.CommandText = selectCommand;

    using (MySqlDataAdapter adapter = new MySqlDataAdapter(Command))
    {
        adapter.Fill(data);
    }
    CloseConnection();
    return data;
}
  

Я бы предложил следующий метод для асинхронной передачи моих данных, но я не знаю, правильно ли это, согласно сообщению в MSDN.

 public async Task<DataTable> SelectDataAsync(string selectCommand)
{
    return await Task.Run(() => SelectData(selectCommand));
}
  

Кроме того, рассмотрим следующий метод:

 public void Query(string sqlCommand)
{
    OpenConnection();
    Command.CommandText = sqlCommand;
    Command.CommandType = CommandType.Text;
    Command.ExecuteNonQuery();
    CloseConnection();
}
  

Как мне написать этот метод, если я хочу поддерживать как асинхронный, так и синхронный? Я имею в виду, что я мог бы написать один и тот же код дважды, но вместо вызова синхронного метода я использую асинхронный.

 public async QueryAsync(string sqlCommand)
{
    OpenConnection();
    Command.CommandText = sqlCommand;
    Command.CommandType = CommandType.Text;
    await Command.ExecuteNonQueryAsync();
    CloseConnection();
}
  

Опять тот же сценарий. Я не должен использовать Task.Запуск для работы с привязкой ввода-вывода, но я не хочу писать почти один и тот же код дважды.

Кто-нибудь может уточнить, как это сделать правильно?

MySqlDataAdapter имеет метод FillAsync. Вы могли бы заменить свой код на :

 public async Task<DataTable> SelectData(string selectCommand)
{
    using(var conn=new MySqlConnection(...))
    using( var cmd=new MySqlCommand(selectCommand,conn))
    using (MySqlDataAdapter adapter = new MySqlDataAdapter(cmd))
    {

        DataTable data = new DataTable()
        await adapter.FillAsync(data);
        return data;
    }
}
  

Однако вместо использования DataTable со слабым типом, возможно, лучшим решением было бы использовать, например, Dapper и возвращать строго типизированную коллекцию, например :

 public async Task<List<Customers>> SelectData(string selectCommand)
{
    using(var conn=new MySqlConnection(...))
    {
        var results=await conn.QueryAsync<Customers>(selectCommand);
        return results.ToList();
    }
}
  

Использование Dapper упрощает использование параметризованных запросов, указывая параметры с помощью анонимных типов, например :

 var publishers = await connection.QueryAsync<Publisher>(
    "select * from Publishers where Name = @name", 
    new { Name = "O'Reilly" });
  

Попробуйте использовать это имя с конкатенацией строк….

Если вам действительно нужны динамические результаты, вы можете использовать dynamic вместо определенного типа.

Но я не понимаю, почему я не должен использовать Task.Запуск для извлечения данных из базы данных.

Потому что это просто смещает проблему, а не решает ее; это заблокирует поток ThreadPool, а не текущий поток, ожидая ввода-вывода.

Если вы нацелены на настольное приложение, это может быть не серьезной проблемой, но это приведет к снижению масштабируемости в веб-приложении.

Как мне написать этот метод, если я хочу поддерживать как асинхронный, так и синхронный?

Как правило, если вам нужно поддерживать обе парадигмы, потребуется некоторое дублирование, однако вы все равно можете повторно использовать некоторые общие части:

 private void CreateCommand(string sqlCommand)
{
    OpenConnection();
    Command.CommandText = sqlCommand;
    Command.CommandType = CommandType.Text;
}

public void Query(string sqlCommand)
{
    CreateCommand(sqlCommand)
    Command.ExecuteNonQuery();
    CloseConnection();
}

public async Task QueryAsync(string sqlCommand)
{
    CreateCommand(sqlCommand)
    await Command.ExecuteNonQueryAsync();
    CloseConnection();
}
  

Но как я должен использовать адаптер данных для извлечения данных.

Использование неблокирующего FillAsync :

 public async Task<DataTable> SelectData(string selectCommand)
{
    //...

    using (MySqlDataAdapter adapter = new MySqlDataAdapter(Command))
    {
        await adapter.FillAsync(data);
    }
    CloseConnection();
    return data;
}
  

Или вы могли бы использовать ExecuteReaderAsync в сочетании с DataTable.Load :

 public async Task<DataTable> SelectData(string selectCommand)
{
    //...

    data.Load(await Command.ExecuteReaderAsync());
    
    CloseConnection();
    return data;
}