Это правильный дизайн синхронизации с блокировкой? - PullRequest
Новая
       27

Это правильный дизайн синхронизации с блокировкой?

5 голосов
/ 08 апреля 2010

У меня есть система, которая берет образцы. У меня есть несколько клиентских потоков в приложении, которые заинтересованы в этих образцах, но фактический процесс взятия образца может происходить только в одном контексте. Он достаточно быстрый, чтобы можно было блокировать вызывающий процесс до завершения выборки, но достаточно медленный, поэтому я не хочу, чтобы несколько потоков копировали запросы. Я придумал этот дизайн (урезанный до минимальных деталей): 

public class Sample
{
    private static Sample _lastSample;
    private static int _isSampling;

    public static Sample TakeSample(AutomationManager automation)
    {
        //Only start sampling if not already sampling in some other context
        if (Interlocked.CompareExchange(ref _isSampling, 0, 1) == 0)
        {
            try
            {
                Sample sample = new Sample();
                sample.PerformSampling(automation);
                _lastSample = sample;
            }
            finally
            {
                //We're done sampling
                _isSampling = 0;
            }
        }

        return _lastSample;
    }

    private void PerformSampling(AutomationManager automation)
    {
        //Lots of stuff going on that shouldn't be run in more than one context at the same time
    }
}

Безопасно ли это для использования в описанном мной сценарии?

Ответы [ 2 ]

5 голосов
/ 08 апреля 2010

Да, это выглядит безопасно, потому что int здесь атомный тип.Но я бы все же посоветовал заменить 

private static int _isSampling;

на 

private static object _samplingLock = new object();

и использовать: 

lock(_samplingLock)
{
    Sample sample = new Sample();
    sample.PerformSampling(automation);
   _lastSample = sample;
}

Просто потому, что это рекомендуемый шаблон, а также обеспечивает доступ ко всем_lastSample обрабатывается правильно.

Примечание: я ожидаю сопоставимой скорости, блокировка использует управляемый класс Monitor, который использует внутреннюю блокировку.

Редактировать:

Я пропустил аспект отсрочки, вот другая версия: 

   if (System.Threading.Monitor.TryEnter(_samplingLock))
   {
     try
     {
         .... // sample stuff
     }
     finally
     {
          System.Threading.Monitor.Exit(_samplingLock);
     }
   }
0 голосов
/ 08 апреля 2010

Я обычно объявляю изменчивый бул и делаю что-то вроде: 

private volatile bool _isBusy;
private static Sample _lastSample;

private Sample DoSomething()
{
     lock(_lastSample)
     {
       if(_isBusy)
          return _lastSample;
       _isBusy = true;
     }

     try
     {
       _lastSample = new sameple//do something
     }
     finally
     {
        lock(_lastSample)
        {
           _isBusy = false;
        }
     }
     return _lastSample;
}
...