Async для массовой копии

Question

У меня есть довольно много данных, которые могут быть загружены в базу данных Из-за большого размера одна таблица занимает 5 минут, чтобы завершить вставку. 2 стола у меня ушло 10 минут

static void Main(string[] args) 
{ 
    DataTableBulkInsert(DataTable1); 
    DataTableBulkInsert(DataTable2); 
} 

public static void DataTableBulkInsert(DataTable Table){ 
    SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(myConnection); 
    sqlBulkCopy.DestinationTableName = "dbo.DatabaseTable"; 
    myConnection.Open();      
    sqlBulkCopy.WriteToServer(Table); 
    myConnection.Close(); 
} 

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

static void Main(string[] args) 
{ 
    var insert1 = Task.Run(async() => await DataTableBulkInsert(DataTable1); 
    var insert2 = Task.Run(async() => await DataTableBulkInsert(DataTable2); 
    Task.WhenAll(insert1, insert 2); 
} 

public static async Task<Boolean> DataTableBulkInsert(DataTable Table) 
{ 
     try 
     { 
      SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(myConnection); 
      sqlBulkCopy.DestinationTableName = "dbo.DatabaseTable"; 
      myConnection.Open();      
      await sqlBulkCopy.WriteToServerAsync(Table); 
      myConnection.Close(); 
     } 
     catch (Exception (e)) 
     { 
     console.write(e); 
     } 
     return true; 
} 

Answer 1

Task.Run s ничего не добавляет. Кроме того, не пытайтесь совместно использовать одно соединение объект между двумя запусками вашего метода. Что-то вроде:

static void Main(string[] args) 
{ 
    var insert1 = DataTableBulkInsert(DataTable1); 
    var insert2 = DataTableBulkInsert(DataTable2); 
    Task.WaitAll(insert1, insert2); 
} 

public static async Task DataTableBulkInsert(DataTable Table) 
{ 
     using(var localConnection = new SqlConnection(/* connection string */)) 
     { 
      SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(localConnection); 
      sqlBulkCopy.DestinationTableName = "dbo.DatabaseTable"; 
      localConnection.Open();      
      await sqlBulkCopy.WriteToServerAsync(Table); 
     } 
} 

Нормально return await является анти-модель, но здесь вы хотите использовать его таким образом, чтобы using заявление не закрывает соединение, пока после того, как основная нагрузка будет завершена.

Кроме того, я перешел на использование Task.WaitAll, который фактически ждет, что больше, чем при использовании идиоматических Task.WhenAll, а затем сразу же вызова Wait на него.

Answer 2

Task.WhenAll возвращает объект Task, который должен быть ожидаемым или код, который следует продолжает свою нормальную работу, и основной метод выходит немедленно.

Поскольку это консольное приложение и главное не могут быть помечены как async, вы можете использовать это:

Task.WhenAll(insert1, insert2).Wait(); // wait for the returned Task object to Complete 

Нормальное использование является: await (Task.WhenAll(...)), но вы не можете пометить Main как async метод ,