lsm/Orchard
1
0
Fork 0
mirror of https://github.com/OrchardCMS/Orchard.git synced 2025-10-15 19:54:57 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Added thread synchronization.

Browse Source 
This ensures that only one thread at a time can acquire a lock.
This commit is contained in:
Sipke Schoorstra
2015-08-10 13:24:54 +01:00
parent 5813647574
commit 15e6c95740
1 changed files with 29 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/Orchard/Tasks/Locking/DistributedLockService.cs
View File

@@ -1,10 +1,12 @@
using System;
using System.Threading;
using System.Threading.Tasks;
using Orchard.Environment;
using Orchard.Logging;
namespace Orchard.Tasks.Locking {
public class DistributedLockService : IDistributedLockService {
private static readonly object _semaphore = new object();
private readonly Work<IDistributedLock> _lock;
private readonly IMachineNameProvider _machineNameProvider;
@@ -17,22 +19,35 @@ namespace Orchard.Tasks.Locking {
public ILogger Logger { get; set; }
public bool TryAcquireLock(string name, TimeSpan maxLifetime, TimeSpan timeout, out IDistributedLock @lock) {
var waitedTime = TimeSpan.Zero;
var waitTime = TimeSpan.FromMilliseconds(timeout.TotalMilliseconds / 10);
@lock = _lock.Value;
bool acquired;
while (!(acquired = @lock.TryAcquire(name, maxLifetime)) && waitedTime < timeout) {
Task.Delay(timeout).ContinueWith(t => {
waitedTime += waitTime;
}).Wait();
}
var machineName = _machineNameProvider.GetMachineName();
@lock = _lock.Value;
if (acquired) {
Logger.Debug(String.Format("Successfully acquired a lock named {0} on machine {1}.", name, machineName));
return true;
if (Monitor.TryEnter(_semaphore)) {
try {
var waitedTime = TimeSpan.Zero;
var waitTime = TimeSpan.FromMilliseconds(timeout.TotalMilliseconds / 10);
bool acquired;
while (!(acquired = @lock.TryAcquire(name, maxLifetime)) && waitedTime < timeout) {
Task.Delay(timeout).ContinueWith(t => {
waitedTime += waitTime;
}).Wait();
}
if (acquired) {
Logger.Debug(String.Format("Successfully acquired a lock named {0} on machine {1}.", name, machineName));
return true;
}
}
catch (Exception ex) {
Logger.Error(ex, "Error during acquire lock.");
throw;
}
finally {
Monitor.Exit(_semaphore);
Logger.Debug("Ending sweep.");
}
}
Logger.Debug(String.Format("Failed to acquire a lock named {0} on machine {1}.", name, machineName));