Wie erzwinge ich einen Mutex auf einem Delegaten

Question

Ich versuche, eine generische Methode zu erstellen, die einen Delegaten akzeptiert. Der einzige Zweck der Methode besteht darin, sicherzustellen, dass jeder eindeutige Codeblock, den Sie an ihn übergeben, nur von jeweils einem Thread gleichzeitig aufgerufen wird. Ich betone das Wort einzigartig, da eindeutige Codeblöcke nebeneinander laufen können, müssen doppelte Codeblöcke synchron laufen. Gibt es ein sauberes Muster, um dies zu erreichen?

Answer 1

Sie können etwas tun:

namespace RunSafe 
{ 
    // Declare a delegate type 
    public delegate void RunSafeDelegate(); 


    public class SafeRunner 
    { 
     private object _lock = new Object(); 

     public void Runner(RunSafeDelegate runsafe) 
     { 
      lock(this._lock) 
      { 
       runsafe(); 
      } 
     } 
    } 
} 

Answer 2

Letztlich mich Dex Star Codebeispiel führen den Weg nach unten die ich suchte.

Wenn es irgendwelche Bedenken gibt, lass es mich wissen. Ich glaube, das ist eine solide Lösung. Hinweis: Ich verwende absichtlich einen benannten Mutex, da beim Zugriff auf Ressourcen möglicherweise mehrere Prozesse beteiligt sind.

// test code 
RunSafeDelegate rsd1 =() => { /* some code i need synchronous */ }; 
RunSafeDelegate rsd2 =() => { /* other code i need synchronous */ }; 

var util = new UtilityClass(); 
util.RunSafe(rsd1, "myMutexName1"); 
util.RunSafe(rsd2, "myMutexName2"); 

// implementation 
public class UtilityClass 
{ 
    public delegate void RunSafeDelegate(); 

    public void RunSafe(RunSafeDelegate runSafe, string mutexName) 
    { 
     const int WAIT_ONE_TIMEOUT = 30000; 

     var sid = new SecurityIdentifier(WellKnownSidType.WorldSid, null); 
     var mar = new MutexAccessRule(sid, MutexRights.FullControl, AccessControlType.Allow); 
     var ms = new MutexSecurity(); 

     ms.AddAccessRule(mar); 

     bool mutexCreated; 

     using(var mutex = new Mutex(false, mutexName, out mutexCreated, ms)) 
     { 
      var signalReceived = false; 

      try 
      { 
       try 
       { 
        signalReceived = mutex.WaitOne(WAIT_ONE_TIMEOUT, false); 

        if(!signalReceived) 
        { 
         throw new TimeoutException("Exclusive access timeout for mutex: " + mutexName); 
        } 
       } 
       catch(AbandonedMutexException) 
       { 
        signalReceived = true; 
       } 

       runSafe(); 
      } 
      finally 
      { 
       if(signalReceived) 
       { 
        mutex.ReleaseMutex(); 
       } 
      } 
     } 
    } 
}