Сбой при работе с временными окнами из-за нескольких потоков

Question

Я работаю над простой веб-службой, которая экспортирует данные из некоторого хранилища данных в базу данных.

Услуга проходит каждые 20 секунд (интервал тестирования).

Интервалы реализуются через класс System.Timers.Timer.

Что происходит на данный момент:

1. служба начинает
2. Таймер начинает
3. 20 секунд проходит и обслуживание начинается экспорт
4. Экспорт не закончить в течение следующих 20 секунд, а другой нить запускает попытку сделать тот же экспорт.
5. В конечном итоге сбой при обслуживании.

Я собирался обернуть экспорт в отдельный поток, но не уверен, полностью ли это устранит проблему.

Увеличение интервала времени не является вариантом, потому что я не уверен, насколько велика будет будущий экспорт.

Любые предложения приветствуются.

Спасибо

Edit:

Я думаю, что я после: 1. Запуск таймера 2. Начало резьбы 3. Начало экспорта 4. Не позволяйте таймер чтобы начать другой поток до тех пор, пока предыдущий не завершится ...

Answer 1

Как насчет в шаге 3 вы сначала отключите таймер, а затем, когда закончите с экспортом, вы снова включите таймер?

Answer 2

Я бы сделал что-то вроде этого.

public class MyServiceController 
{ 
    private Thread m_Thread = new Thread(() => { Run(); }); 
    private ManualResetEvent m_StopSignal = new ManualResetEvent(); 

    public void Start() 
    { 
    m_Thread.Start(); 
    } 

    public void Stop() 
    { 
    m_StopSignal.Set(); // Give it chance to end on its own. 
    if (!m_Thread.Join(TimeSpan.FromSeconds(30)) 
    { 
     // Tear everything down forcefully as an absolute last resort. 
     m_Thread.Abort(); 
    } 
    } 

    private void Run() 
    { 
    while (!m_StopSignal(TimeSpan.FromSeconds(20)) 
    { 
     // Put your code here. 
    } 
    } 
} 

Этот подход выделяет отдельный выделенный поток для обработки, который сохраняет все синхронным. Обратите внимание, что для изменения интервалов используется WaitHandle. Также важно отметить, что я упустил много кода, который сделает MyServiceController более надежным, как работа с абонентами, которые хотят позвонить по телефону Start несколько раз, убедившись, что рабочий поток завершен, если он не хочет останавливаться мирно и т. Д.

Answer 3

Иногда вы не хотите останавливать свой таймер, потому что он может порождать несколько потоков. В этом случае вы завершаете критические части каждого потока в блоке Monitor.TryEnter, блокируя общий объект, так что если поток все еще работает, когда таймер снова срабатывает, новый поток проходит безвредно.

private static object lockObject = new object(); 
public void DoSomething() 
{ 
    if (System.Threading.Monitor.TryEnter(lockObject)) 
    { 
     try 
     { 
      // critical stuff 
     } 
     finally 
     { 
      System.Threading.Monitor.Exit(lockObject); 
     } 
    } 
}