lafar6502

    public class ConcurrentGateway
    {
        private ConcurrentQueue<Action> _workQueue = new ConcurrentQueue<Action>();
        private  int _writeLock = 0;

        [ThreadStatic]
        private static AutoResetEvent _waitEvent = new AutoResetEvent(false);

        protected static AutoResetEvent GetThreadWaitEvent()
        {

PaulStovell

using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Threading;
using Raven.Abstractions.Data;
using Raven.Client.Embedded;
using Raven.Client.Indexes;

namespace OctoQueues

kijanawoodard

using System;
using System.Linq;
using Raven.Abstractions.Data;
using Raven.Abstractions.Logging;
using Raven.Bundles.Replication.Plugins;
using Raven.Json.Linq;

namespace RavenConflictResolverPlugin
{
    public class LastInWinsReplicationConflictResolver

jpv001

void Main()
    {
        var d = new Dictionary<BigInteger, BigInteger>();
        var t = DateTime.Now;
        var howfar = 0;
        var r = 0;
        for (int x = 0; x < 100000; x++)
        {
            for (int i = 0; i < 10000000; i++)
            {

ToJans

// Data Nat = Z | S Nat
// 
// plus : Nat -> Nat -> Nat
// plus Z y = y
// plus (S k) y = S (plus k y)

abstract class Nat {
}

class Zero : Nat {