Public Class PrimitiveSerializer 
   Implements CSharpTest.Net.Serialization.ISerializer(Of Boolean), CSharpTest.Net.Serialization.ISerializer(Of Byte()), CSharpTest.Net.Serialization.ISerializer(Of Byte), CSharpTest.Net.Serialization.ISerializer(Of Char), CSharpTest.Net.Serialization.ISerializer(Of Date), CSharpTest.Net.Serialization.ISerializer(Of Double), CSharpTest.Net.Serialization.ISerializer(Of Guid), CSharpTest.Net.Serialization.ISerializer(Of Short), CSharpTest.Net.Serialization.ISerializer(Of Integer), CSharpTest.Net.Serialization.ISerializer(Of Long), CSharpTest.Net.Serialization.ISerializer(Of IntPtr), CSharpTest.Net.Serialization.ISerializer(Of SByte), CSharpTest.Net.Serialization.ISerializer(Of Single), CSharpTest.Net.Serialization.ISerializer(Of String), CSharpTest.Net.Serialization.ISerializer(Of TimeSpan), CSharpTest.Net.Serialization.ISerializer(Of UShort), CSharpTest.Net.Serialization.ISerializer(Of UInteger), CSharpTest.Net.Serialization.ISerializer(Of ULong), CSharpTest.Net.Serialization.ISerializer(Of UIntPtr) 

public class PrimitiveSerializer : CSharpTest.Net.Serialization.ISerializer<bool>, CSharpTest.Net.Serialization.ISerializer<byte[]>, CSharpTest.Net.Serialization.ISerializer<byte>, CSharpTest.Net.Serialization.ISerializer<char>, CSharpTest.Net.Serialization.ISerializer<DateTime>, CSharpTest.Net.Serialization.ISerializer<double>, CSharpTest.Net.Serialization.ISerializer<Guid>, CSharpTest.Net.Serialization.ISerializer<short>, CSharpTest.Net.Serialization.ISerializer<int>, CSharpTest.Net.Serialization.ISerializer<long>, CSharpTest.Net.Serialization.ISerializer<IntPtr>, CSharpTest.Net.Serialization.ISerializer<sbyte>, CSharpTest.Net.Serialization.ISerializer<float>, CSharpTest.Net.Serialization.ISerializer<string>, CSharpTest.Net.Serialization.ISerializer<TimeSpan>, CSharpTest.Net.Serialization.ISerializer<ushort>, CSharpTest.Net.Serialization.ISerializer<uint>, CSharpTest.Net.Serialization.ISerializer<ulong>, CSharpTest.Net.Serialization.ISerializer<UIntPtr>  

BPlusTree<int, int>.OptionsV2 options = new BPlusTree<int, int>.OptionsV2(
    new PrimitiveSerializer(), new PrimitiveSerializer());
options.LockTimeout = 100;
options.CallLevelLock = new ReaderWriterLocking();
        
using (BPlusTree<int, int> dictionary = new BPlusTree<int, int>(options))
{
    bool canwrite = false, canread = false;
    ThreadStart proc = delegate()
    {
        try { dictionary[1] = 1; canwrite = true; } catch { canwrite = false; }
        try { int i; dictionary.TryGetValue(1, out i); canread = true; } catch { canread = false; }
    };

    Assert.IsTrue(proc.BeginInvoke(null, null).AsyncWaitHandle.WaitOne(1000, false));
    Assert.IsTrue(canwrite);
    Assert.IsTrue(canread);

    //now we lock the entire btree:
    using (dictionary.CallLevelLock.Write())
    {
        //they can't read or write
        Assert.IsTrue(proc.BeginInvoke(null, null).AsyncWaitHandle.WaitOne(1000, false));
        Assert.IsFalse(canwrite);
        Assert.IsFalse(canread);
        //but we can
        proc();
        Assert.IsTrue(canwrite);
        Assert.IsTrue(canread);
    }
    //lock release all is well
    Assert.IsTrue(proc.BeginInvoke(null, null).AsyncWaitHandle.WaitOne(1000, false));
    Assert.IsTrue(canwrite);
    Assert.IsTrue(canread);

    //We can also make sure noone else gains exclusive access with a read lock
    using (dictionary.CallLevelLock.Read())
    {
        Assert.IsTrue(proc.BeginInvoke(null, null).AsyncWaitHandle.WaitOne(1000, false));
        Assert.IsTrue(canwrite);
        Assert.IsTrue(canread);
    }
}

Dim options As New BPlusTree(Of Integer, Integer).OptionsV2(New PrimitiveSerializer(), New PrimitiveSerializer())
options.LockTimeout = 100
options.CallLevelLock = New ReaderWriterLocking()

Using dictionary As New BPlusTree(Of Integer, Integer)(options)
    Dim canwrite As Boolean = False, canread As Boolean = False
    Dim proc As ThreadStart = Function() Do
        Try
            dictionary(1) = 1
            canwrite = True
        Catch
            canwrite = False
        End Try
        Try
            Dim i As Integer
            dictionary.TryGetValue(1, i)
            canread = True
        Catch
            canread = False
        End Try
    End Function

    Assert.IsTrue(proc.BeginInvoke(Nothing, Nothing).AsyncWaitHandle.WaitOne(1000, False))
    Assert.IsTrue(canwrite)
    Assert.IsTrue(canread)

    'now we lock the entire btree:
    Using dictionary.CallLevelLock.Write()
        'they can't read or write
        Assert.IsTrue(proc.BeginInvoke(Nothing, Nothing).AsyncWaitHandle.WaitOne(1000, False))
        Assert.IsFalse(canwrite)
        Assert.IsFalse(canread)
        'but we can
        proc()
        Assert.IsTrue(canwrite)
        Assert.IsTrue(canread)
    End Using
    'lock release all is well
    Assert.IsTrue(proc.BeginInvoke(Nothing, Nothing).AsyncWaitHandle.WaitOne(1000, False))
    Assert.IsTrue(canwrite)
    Assert.IsTrue(canread)

    'We can also make sure noone else gains exclusive access with a read lock
    Using dictionary.CallLevelLock.Read()
        Assert.IsTrue(proc.BeginInvoke(Nothing, Nothing).AsyncWaitHandle.WaitOne(1000, False))
        Assert.IsTrue(canwrite)
        Assert.IsTrue(canread)
    End Using
End Using