Как я могу управлять элементами в ThreadPool?

Question

У меня есть служба Windows, которая запускает метод, когда истекает срок службы основного таймера (OnElapse).

Метод OnElapse получает список XML-файлов для обработки. Каждый XML-файл вставляется в ThreadPool.

Я хочу, чтобы я не вставлял 2 XML с тем же именем в ThreadPool.

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

if xmlfilename not in threadpool 
    insert in threadpool 

Answer 1

Это довольно трюк, потому что вам нужно внимательно следить за ThreadPool, и для этого потребуется форма синхронизации. Вот быстрый и грязный пример способа сделать это.

class XmlManager { 
    private object m_lock = new object(); 
    private HashSet<string> m_inPool = new HashSet<string>(); 

    private void Run(object state) { 
    string name = (string)state; 
    try { 
     FunctionThatActuallyProcessesFiles(name); 
    } finally { 
     lock (m_lock) { m_inPool.Remove(name); } 
    } 
    } 

    public void MaybeRun(string xmlName) { 
    lock (m_lock) { 
     if (!m_pool.Add(xmlName)) { 
     return; 
     } 
    } 
    ThreadPool.QueueUserWorkItem(Run, xmlName); 
    } 
} 

Это не надежное решение. В коде есть по крайней мере одно условие гонки. А именно, что элемент можно удалять из пула, пока вы пытаетесь его добавить, и на самом деле он не будет добавлен. Но если ваши вопросы касаются только того, что они обрабатываются один раз, это не имеет значения.

Answer 2

OnElaspe Вы не можете переименовать xml-файл? поэтому он имеет имя unqiue в threadpool.

Answer 3

Не могли бы вы сделать словарь> и проверить это, прежде чем делать ввод? Что-то вроде этого ...

Dictionary<ThreadPool, List<String>> poolXmlFiles = new Dictionary<ThreadPool, List<String>>(); 
if(poolXmlFiles.ContainsKey(ThreadPool) && !poolXmlFiles[ThreadPool].Contains(xmlFileName)) 
{ 
    poolXmlFiles[ThreadPool].Add(xmlFileName); 
    //Add the xmlFile to the ThreadPool 
} 

Извините, если есть синтаксические ошибки, в настоящее время я кодирую в VB.

Answer 4

Нечто подобное должно сделать это (используйте HashSet вместо словаря, если вы используете .NET 3.5 или выше):

using System; 
using System.Collections.Generic; 
using System.Threading; 

namespace Something 
{ 
    class ProcessFilesClass 
    { 
     private object m_Lock = new object(); 
     private Dictionary<string, object> m_WorkingItems = 
      new Dictionary<string, object>(); 
     private Timer m_Timer; 

     public ProcessFilesClass() 
     { 
      m_Timer = new Timer(OnElapsed, null, 0, 10000); 
     } 

     public void OnElapsed(object context) 
     { 
      List<string> xmlList = new List<string>(); 
      //Process xml files into xmlList 

      foreach (string xmlFile in xmlList) 
      { 
       lock (m_Lock) 
       { 
        if (!m_WorkingItems.ContainsKey(xmlFile)) 
        { 
         m_WorkingItems.Add(xmlFile, null); 
         ThreadPool.QueueUserWorkItem(DoWork, xmlFile); 
        } 
       } 
      } 
     } 

     public void DoWork(object xmlFile) 
     { 
      //process xmlFile 
      lock (m_Lock) 
      { 
       m_WorkingItems.Remove(xmlFile.ToString()); 
      } 
     } 
    } 
}