Как убедиться, что конечная точка не выполняет метод, если он уже запущен?

Question

У меня есть конечная точка, которая запускает метод. Я хочу, чтобы этот метод не выполнялся во время его запуска, когда я несколько раз ударял конечную точку.

Я предполагаю, что могу установить переменную где-то в пуле потоков или что-то в этом роде? Я не уверен, как это сделать. Некоторые из них будут оценены.

Мой пример:

namespace Website.Import 
{ 
    public class ImportProducts : IHttpHandler 
    { 
     private static bool running = false; 
     public void ProcessRequest(HttpContext context) 
     { 
      context.Response.ContentType = "application/json"; 

      if (running) 
      { 
       throw new Exception("Already running"); 
      } 

      running = true; 

      try 
      { 
       var repo = new MemoryRepository(); 

       var productImporter = new ProductImporter(repo); 
       var groupImporter = new GroupImporter(repo); 
       var discountImporter = new DiscountImporter(repo); 
      } 
      finally 
      { 
       running = false; 
      } 

      context.Response.Write("Done"); 

     } 

     public bool IsReusable 
     { 
      get 
      { 
       return true; 
      } 
     } 
    } 
} 

Answer 1

Вы можете создать объект блокировки для обеспечения действия не запускается параллельно.

private static object lockObject = new object(); 

lock (lockObject) 
{ 
    // your code 
} 

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

Это поведение может быть преднамеренным. Если вы хотите заблокировать выполнение для всех сеансов, этот код в порядке. Если вы хотите заблокировать выполнение только для этого пользователя, позволяя методу запускать один раз в одно время для пользователя, вы должны поместить объект в хранилище сеансов.

Если вы просто хотите, чтобы сообщить клиенту, что уже работает, вы можете также бросить исключение:

private static bool alreadyExecuting = false; 

if (alreadyExecuting) 
{ 
    throw new Exception("Already running"); 
} 

alreadyExecuting = true; 

try 
{ 
    // your code 
} 
finally 
{ 
    alreadyExecuting = false; 
}