Параллельный вызов хранимой процедуры для увеличения счетчика и обеспечения атомарных приращений

Используйте 1_

DECLARE @temp TABLE (MaxReached BIT NOT NULL);

UPDATE SomeCounters
  SET CounterValue = (CounterValue + @AddValue),
      MaxReached = CASE WHEN MaxValue = (CurrentValue + 1) THEN 1 ELSE 0
  WHERE CounterId = @CounterId
    AND MaxReached = 0
  OUTPUT INSERTED.MaxReached INTO @temp

Обновление является атомарным, и вы можете затем выбрать значение из таблицы @temp и делать с ним все, что хотите. Таким образом, вы сможете зафиксировать точное обновление, из-за которого для MaxReached было установлено значение true (1).

Вам нужно обернуть его в транзакцию и добавить выбор в той же транзакции, как показано ниже:

BEGIN TRANSACTION; 

UPDATE SomeCounters
SET CounterValue = (CounterValue + @AddValue)
WHERE CounterId = @CounterId;

SELECT CASE WHEN MaxValue = CurrentValue THEN 1 ELSE 0 MaxReached
FROM SomeCounters
WHERE CounterId = @CounterId;

COMMIT TRANSACTION;

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

Один из способов добиться того, что вы ищете, — это придерживаться пессимистического подхода; это означает, что каждая хранимая процедура обновляет запись только в том случае, если она не была изменена другой хранимой процедурой, и повторяет попытку, пока не будет достигнуто максимальное значение. Для этого вам нужно прочитать текущее значение перед обновлением, а затем обновить запись с предложением WHERE, которое ожидает, что значение будет таким же. Вам также нужен цикл, если вам нужно убедиться, что вызов в конечном итоге увенчается успехом. Используя этот подход, только 1 хранимая процедура будет обновлять таблицу за раз и повторять работу, пока не будет достигнуто максимальное значение.

Что-то вроде этого:

DECLARE @savedValue int
DECLARE @maxedReached int
-- read current values for concurrency
SELECT @savedValue = CounterValue, @maxedReached = MaxReached 
  FROM SomeCounters WHERE CounterId = @counterId)

WHILE(@maxedReached = 0)
BEGIN

  UPDATE SomeCounters
  SET CounterValue = (CounterValue + @AddValue),    
    MaxReached = CASE WHEN MaxValue = (CurrentValue + 1) THEN 1 ELSE 0 END
  WHERE 
    CounterId = @CounterId  
    AND MaxReached = 0
    -- the next clause ensures that only one stored procedure will succeed
    AND CounterValue = @savedValue  

  if (@@rowcount = 0)
  BEGIN
    -- failed... another procedure made the change?
    -- If @maxReached becomes 1, the loop will exit and you will
    -- know the maximum was reached; if not the loop will try updating
    -- the value again
    -- read the values for concurrency again.
    SELECT @savedValue = CounterValue, @maxedReached = MaxReached 
        FROM SomeCounters WHERE CounterId = @counterId)

  END
END

Другая стратегия, которую я изучаю, — это использование sp_getapplock внутри транзакции. Кажется, это позволило бы мне создать уникальную строку для счетчика, который я пытаюсь обновить, и заблокировать другие одновременные выполнения, пока он не будет завершен.

Это кажется особенно полезным, поскольку моя процедура также будет содержать некоторую логику IF EXISTS... ELSE..., которая будет обрабатывать либо создание записи счетчика в первый раз, либо обновление существующей записи.

http://msdn.microsoft.com/en-us/library/ms189823.aspx - sp_getapplock

Предполагая, что MaxValue хорошо известен и одинаков для каждого счетчика, вам не нужны транзакции:

UPDATE CounterTable
SET Counter=Counter+1
WHERE CounterId = @CounterId

Это база данных, а не многопоточная программа. Это запрос к SQL Server на увеличение значения столбца Counter одной строки таблицы. SQL Server сделает это - я не думаю, что это позволит таблице потерять один из запросов.

Так что в худшем случае вы можете получить Counter > MaxValue. Но если вы знаете, что такое MaxValue, то вы знаете, что любое значение выше этого значения на самом деле означает MaxValue. Нет необходимости мгновенно планировать работу в той же транзакции.

Таким образом, в зависимости от того, насколько критической по времени является «дополнительная работа», просто попросите задание или другую программу запросить таблицу в поисках любых значений счетчика, больших или равных MaxValue, и сразу же выполните работу. В худшем случае создайте триггер, который будет срабатывать при каждом ОБНОВЛЕНИИ, который работает только при высоком значении счетчика.

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