Блог

У меня есть длительный процесс, ImportProductInformation вызываемый консольным приложением, который я пытаюсь ускорить, который, как представляется, является отличным кандидатом для объединения потоков, поэтому я немного поискал и наткнулся на SmartThreadPool в CodeProject и пытаюсь его реализовать.

ImportProductInformation в настоящее время требуется «элемент», который представляет собой всего лишь одну строку entity-framework, извлеченную из списка. SmartThreadPool использует вызываемый делегат "WorkItemCallback" , но если я создаю его, как показано ниже, он жалуется на «Ожидаемое имя метода» в цикле foreach на smartThreadPool.QueueWorkItem , поскольку, похоже, я не могу передать свои параметры делегированному методу. Чего мне здесь не хватает? Я уверен, что это что-то глупое … новичку не хватает опыта работы с делегатами…любая помощь была бы оценена:

     public static void ImportProductInformation_Exec()
    {
        // List
        List<productinformation> _list = GetProductInformation();

        // Import
        if (_list != null)
        {
            SmartThreadPool smartThreadPool = new SmartThreadPool();

            foreach (var item in _list)
            {
                smartThreadPool.QueueWorkItem
                  (new WorkItemCallback
                    (ImportProductInformation(item)));
            }

            smartThreadPool.WaitForIdle();
            smartThreadPool.Shutdown();
        }
    }

    public void ImportProductInformation(productinformation item)
    {
        // Do work associated with "item" here
    }
  

Если я изменю цикл на этот, я получу «Метод используется как тип» в ошибке сборки:

             foreach (var item in _list)
            {
                ImportProductInformation ipi = 
                  new ImportProductInformation(item);

                smartThreadPool.QueueWorkItem(new WorkItemCallback(ipi));
            }
  

В итоге получилось заставить его работать с этим:

 public class ProductInformationTaskInfo
{
    public productinformation ProductInformation;

    public ProductInformationTaskInfo(productinformation pi)
    {
        ProductInformation = pi;
    }
}

public class PI
{
    foreach (var item in _list)
    {
        ProductInformationTaskInfo pi = 
          new ProductInformationTaskInfo(item);
        smartThreadPool.QueueWorkItem
          (new WorkItemCallback
            (ImportProductInformation), pi);
    }

    public static object ImportProductInformation(Object _pi)
    {
        ProductInformationTaskInfo pi = (ProductInformationTaskInfo)_pi;
        var item = pi.ProductInformation;

        // Do work here
    }
}
  

Я не знаю или не имею SmartThreadPool, следующее является приблизительным:

 foreach (var item in _list)
{
   var itemCopy = item;
   smartThreadPool.QueueWorkItem
              (dummy => ImportProductInformation(itemCopy));
}
  

Возможно, вам придется внести некоторые исправления.
Это работает, потому что лямбда-выражение фиксирует переменную из содержащего метода. И именно поэтому вам нужна itemCopy.

Но обратите внимание, что обычный ThreadPool не подходит для длительных задач, то же самое может относиться и к SmartThreadPool. Также следует ограничить количество потоков, и когда ImportProductInformation выполняет в основном потоки ввода-вывода, это может вообще не помочь.

Вы можете использовать анонимные методы:

 int a = 15;
String b = "hello world!";
ThreadPool.QueueUserWorkItem((state)=>SomeFunction(a,b));