slock4net

High-performance distributed sync service and atomic DB. Provides good multi-core support through lock queues, high-performance asynchronous binary network protocols. Can be used for spikes, synchronization, event notification, concurrency control. https://github.com/snower/slock

Install

NuGet\Install-Package slock4net -Version 1.0.3

Client Lock

using slock4net.Exceptions;
using slock4net;

SlockClient client = new SlockClient("localhost", 5658);
try
{
    client.Open();
    Lock lck = client.NewLock("test", 5, 5);
    lck.Acquire();
    lck.Release();
}
catch (IOException e) {
    Console.WriteLine(e.ToString());
}
catch (SlockException e) {
    Console.WriteLine(e.ToString());
} finally
{
    client.Close();
}
Console.WriteLine("Success");

Replset Client Lock

using slock4net.Exceptions;
using slock4net;

SlockReplsetClient replsetClient = new SlockReplsetClient(new String[] { "localhost:5658" });
try
{
    replsetClient.Open();
    Lock lck = replsetClient.NewLock("test", 5, 5);
    lck.Acquire();
    lck.Release();
}
catch (IOException e) {
    Console.WriteLine(e.ToString());
}
catch (SlockException e) {
    Console.WriteLine(e.ToString());
} finally
{
    replsetClient.Close();
}
Console.WriteLine("Success");

Async Client Lock

using slock4net.Exceptions;
using slock4net;

async Task TestLock()
{
    SlockReplsetClient replsetClient = new SlockReplsetClient(new String[] { "localhost:5658" });
    try
    {
        await replsetClient.OpenAsync();
        Lock lck = replsetClient.NewLock("test", 5, 5);
        await lck.AcquireAsync();
        await lck.ReleaseAsync();
    }
    catch (IOException e)
    {
        Console.WriteLine(e.ToString());
    }
    catch (SlockException e)
    {
        Console.WriteLine(e.ToString());
    }
    finally
    {
        await replsetClient.CloseAsync();
    }
}
TestLock().Wait();
Console.WriteLine("Success");

Event

using slock4net.Exceptions;
using slock4net;

SlockClient client = new SlockClient("localhost", 5658);
try
{
    client.Open();
    Event event1 = client.NewEvent("test", 5, 5, true);
    event1.Clear();

    Event event2 = client.NewEvent("test", 5, 5, true);
    event2.Set("{\"value\": 10}");

    event1.Wait(10);
    Console.WriteLine(event1.CurrentLockDataAsString);
}
catch (IOException e) {
    Console.WriteLine(e.ToString());
}
catch (SlockException e) {
    Console.WriteLine(e.ToString());
} finally
{
    client.Close();
}
Console.WriteLine("Success");