błąd Wielowątkowość: Jest już otwarty DataReader skojarzony z tym połączeniem, które muszą być zamknięte pierwszy

Question

mam pętlę Parallel.Foreach

var options = new ParallelOptions(); 
options.MaxDegreeOfParallelism = 1; 
Parallel.ForEach(urlTable.AsEnumerable(),drow => 
{ 
    using (var WCC = new MasterCrawlerClass()) 
    { 
     WCC.MasterCrawlBegin(drow); 
    } 
} 

Pętla ta wywołuje klasę i pętle za pośrednictwem wszystkich moich wierszy DataRows, jednak każdy z te pliki danych albo wypełniają DataTable, albo wykonują polecenie aktualizacji do MySQL DB. Kod, który mam dla obydwu, znajduje się poniżej.

private static DataTable DTTable(string mysqlQuery, string queryName) 
{ 
    DataTable DTTableTable = new DataTable(); 
    try 
    { 
     MySqlDataAdapter DataDTTables = new MySqlDataAdapter(mysqlQuery, MySQLProcessing.MySQLStatic.Connection); 
     DataTable DataDTTablesDT = new DataTable(); 
     DataDTTables.SelectCommand.CommandTimeout = 240000; 
     DataDTTables.Fill(DataDTTablesDT); 
     DTTableTable = DataDTTablesDT; 

    } 
    catch (Exception ex) 
    { 

     GenericLogging("Failed MySQLquery: " + ex.Message.ToString(), "MySQLProcessor", "DTTable", "", "MysqlError", "", queryName, mysqlQuery); 

    } 
    return DTTableTable; 
} 

private static void MySQLInsertUpdate(string MySQLCommand, string mysqlcommand_name) 
{ 
    try 
    { 
     MySqlCommand MySQLCommandFunc = new MySqlCommand(MySQLCommand, MySQLProcessing.MySQLStatic.Connection); 
     MySQLCommandFunc.CommandTimeout = 240000; 
     MySQLCommandFunc.ExecuteNonQuery(); 
    } 
    catch (Exception ex) 
    { 
     GenericLogging("Failed MySQLquery: " + ex.Message.ToString(), "MySQLProcessor", "DTTable", "", "MysqlError", "", mysqlcommand_name, MySQLCommand); 
    } 
} 

Rzecz WCC zawiera 10 lub tak pustych przestrzeni, przy czym wszystkie puste przestrzenie uzyskuje dostęp do funkcji MySQL co najmniej raz. Więc jeśli blokowanie jest odpowiedzią, czy jest możliwe utworzenie 1 funkcji blokowania dla wszystkich pustek? Jeśli tak to jak? Jeśli jest inny sposób, proszę dać mi znać

Dzięki!

Ok jak sugerowano i skonsolidowane pytania

Kod został obecnie aktualizowane w celu odzwierciedlenia zamek, można znaleźć poniżej.

static readonly object _object = new object();

public static DataTable DTTable(string mysqlQuery, string queryName) 
     { 
      lock (_object) 
      { 
       DataTable DTTableTable = new DataTable(); 
       try 
       { 
        using (MySqlDataAdapter DataDTTables = new MySqlDataAdapter(mysqlQuery, MySQLProcessing.MySQLStatic.Connection)) 
        { 
         using (DataTable DataDTTablesDT = new DataTable()) 
         { 
          DataDTTables.SelectCommand.CommandTimeout = 240000; 
          DataDTTables.Fill(DataDTTablesDT); 
          DTTableTable = DataDTTablesDT; 
          DataDTTables.Dispose(); 
         } 
        } 

       } 
       catch (Exception ex) 
       { 

        GenericLogging("Failed MySQLquery: " + ex.Message.ToString(), "MySQLProcessor", "DTTable", "", "MysqlError", "", queryName, mysqlQuery); 

       } 
       return DTTableTable; 
      } 
     }

To jest tylko kod, który wywołuje DataReader, jak może istnieć dwie otwarte czytniki danych, jeśli istnieje blokada?

Answer 1

Problem polega na tym, że dostawcy danych ADO.NET na ogół nie zezwalają na więcej niż jeden otwarty czytnik danych w czasie połączenia. SQL Server ma koncepcję multiple active result sets (MARS), ale o ile wiem, MySQL jeszcze jej nie obsługuje.

Prawdopodobnie konieczne będzie określenie innego połączenia niż MySQLProcessing.MySQLStatic.Connection. Nic nie powstrzyma cię od korzystania z więcej niż jednego połączenia. Problem polega na tym, że połączenia są drogimi zasobami, więc powinieneś ich używać oszczędnie.

Answer 2

Używasz tego samego połączenia w tym samym czasie.

Czy masz kilka wątków? Ponieważ wydaje się, że 2 wątki używają tego samego połączenia do jednoczesnego wykonywania połączenia.