Темы застряли в MySqlCommand.ExecuteNonQuery()

Question

Я хочу, чтобы вызовы метода были параллельными. В этом методе я вычисляю некоторое значение (очень быстро) и записываю значение этого вычисления в таблицу базы данных.

Поэтому я использую Threadpool

ThreadPool.QueueUserWorkItem((state) => { 
       method(); 
      }); 

Через некоторое время вычисления (не детерминированным, время, когда это происходит, меняется, иногда через несколько минут, иногда через несколько часов) Threadpool полон, но не с потоком метода(), но с потоком моего класса mysql, который вызывает MySqlCommand.ExecuteNonQuery.

Есть ли у кого-нибудь идеи, как этого избежать? В документации по классам mysql я обнаружил, что вы не можете завершить исполняемый запрос, но как избежать таких проблем?

Answer 1

Нужно ли записывать все значения в БД после их расчета, или вы можете подождать, пока у вас их нет, и выполните пакетное обновление, где вы вставляете их много?

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