HCenter.CacheHelper 2.0.6

static void Main(string[] args) { try { //int minWorker, minIOC; //// Get the current settings. //ThreadPool.GetMinThreads(out minWorker, out minIOC); //// Change the minimum number of worker threads to four, but //// keep the old setting for minimum asynchronous I/O //// completion threads. //ThreadPool.SetMinThreads(4, minIOC);

            ICacheProvider cache =
                new MemoryCacheImp("vive") { KeySuffix = "xjh" };
                //new CSRedisCacheImp("vive", 1) { KeySuffix = "xjh" };


            //StackExchange(cache);

            Test_SetValue(cache);
            Test_GetValue_Tasks(cache);
            //CallWithTimeout(FiveSecondMethod, 4000);
            System.Console.ReadKey();
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex);
            System.Console.ReadKey();
        }
    }
    static void Test_SetValue(ICacheProvider cache)
    {
        cache.RemoveAll();
        #region Hash

        cache.HashSet("user", "u1", "123");
        cache.HashSet("user", "u2", "1234");
        cache.HashSet("user", "u3", "1235");
        var news = cache.HashGet<string>("user", "u2");

        #endregion Hash

        List<Person> people = new List<Person>()
        {
            new Person(1, "Joe", new List<Contact>()
            {
                new Contact("1", "0123456789"),
                new Contact("2", "0234567890")
            }),
            new Person(2, "Joe2", new List<Contact>()
            {
                new Contact("12", "1234567289"),
                new Contact("22", "2345672890")
            })
        };
        //for(var i = 2; i < 3003; i++)
        //{
        //    people.Add(new Person(i, "Joe2" + i, new List<Contact>()
        //    {
        //        new Contact("12"+i, "1234567289"+i),
        //        new Contact("22"+i, "2345672890"+i)
        //    }));
        //}

        cache.Set("People", people);
        var getpeople = cache.Get<List<Person>>("People");

        var ret = cache.HashSet("user", "Peoples", people);
        var pps = cache.HashGet<List<Person>>("user", "Peoples");

        ret = cache.HashSet("user", "People", people[1]);

        var pp2s = cache.HashGet<List<Person>>("user", "Peoples");
        var pp = cache.HashGet<Person>("user", "People");


        Dictionary<string, Person> dicPerson = new Dictionary<string, Person>();
        people.ForEach(p => dicPerson[p.Id.ToString()] = p);
        var dics = new Dictionary<string, Dictionary<string, Person>>();
        dics.Add("dicpeople", dicPerson);

       // cache.HashSetExecute("dicpeople", dicPerson);

        cache.HashSetExecute(dics);
        var dicpeoples = cache.HashGetAll<Person>("dicpeople");

        var keys = cache.HashGetAll<object>("user");
    }
    static void Test_GetValue_Tasks(ICacheProvider cache)
    {
        #region Test_GetValue_Tasks
        const int noOfClients = 10000;
        var tasks = new Task[noOfClients];
        var c = 0;
        var ie = 0;
        var locked = 0;
        var watch1 = new Stopwatch();
        //开始计时
        watch1.Start();
        cache.Set("atomic-counter", 0);
        for (var i = 0; i < noOfClients; i++)
        {
            Thread.Sleep(10);
            tasks[i] = Task.Factory.StartNew((object clientNo) =>
            {
                try
                {
                    var token = Environment.MachineName;
                    //if (cache.LockTake("lock_test", token, TimeSpan.MaxValue))
                    using (cache.AcquireLock("lock_test", TimeSpan.FromSeconds(20),true))
                    {
                        try
                        {
                            //TODO:开始做你需要的事情
                            //Thread.Sleep(5000);
                            var watch = new Stopwatch();
                            //开始计时
                            watch.Start();

                            if (!cache.Exists("atomic-counter")) cache.Set("atomic-counter", 0);

                            var contacts = cache.Get<List<Person>>("People");
                            var contactslist = cache.HashGet<List<Person>>("user", "Peoples");
                            //var contactslist = cache.HashGetAll<List<Person>>("user");

                            Thread.Sleep(10);

                            var counter = cache.Get<int>("atomic-counter");
                            cache.Set("atomic-counter", (counter + 1));
                            var atomiccounter = cache.Get<int>("atomic-counter");

                            watch.Stop();

                            Console.WriteLine(cache.GetType().Name + " client {0} released lock,contactslist.Count={1},watch.ElapsedMilliseconds={2},atomic-counter={3}", (int)clientNo, contactslist.Count, watch.ElapsedMilliseconds, atomiccounter);
                        }
                        finally
                        {
                            //cache.LockRelease("lock_test", token);
                        }
                    }
                    //else
                    //{
                    //    locked++;
                    //    var atomiccounter = cache.Get<int>("atomic-counter");
                    //    Console.WriteLine(cache.GetType().Name + " client {0} ,locked={1},atomic-counter={2},is locked:", locked, (int)clientNo, atomiccounter);
                    //}
                }
                catch (Exception e)
                {
                    ie++;
                    var atomiccounter = cache.Get<int>("atomic-counter");
                    Console.WriteLine(cache.GetType().Name + " client {0} ,ie={1},atomic-counter={2},Exception:" + e.Message, ie, (int)clientNo, atomiccounter);
                }

                c++;
                if (noOfClients <= c)
                {
                    watch1.Stop();
                    var atomiccounter = cache.Get<int>("atomic-counter");
                    Console.WriteLine(cache.GetType().Name + " client c={0},ie={1},ElapsedMilliseconds={2} ,atomic-counter={3}", c, ie, watch1.ElapsedMilliseconds, atomiccounter);
                }

            }, i + 1);
        }
        #endregion
    }