using System;
using StackExchange.Redis;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;

namespace ForRedis
{
    class Program
    {
        public volatile static int count = 10;//假如这里是商品的数量10个
        static void Main(string[] args)
        {
            var taskFactory = Task.Factory;
            var taskList = new List<Task>();
            for (int i = 0; i < 100; i++)//模拟100个线程
            {
                taskList.Add(taskFactory.StartNew(toBuy));//模拟多线程抢购
            }
            var taskArray = taskList.ToArray();
            taskFactory.ContinueWhenAll(taskArray, (taskArrays) => { Console.WriteLine("结束了，剩余{0}", count); });

            Console.ReadLine();
        }

        static void toBuy()
        {
            var key = "key";//此处key没有实际意义，只是一个key
            try
            {
                if (RedisManager.db.StringSet(key, "1", TimeSpan.FromMilliseconds(500),When.NotExists))//key的有效期为500ms,此处获取可能会出现异常，需要捕获异常
                {
                    //拿到了锁,减库存
                    if (count > 0)
                    {
                        count--;
                        Console.WriteLine("卖出商品,商品剩余{0}", count);
                    }
                    else
                    {
                        Console.WriteLine("没有更多商品了");
                    }
                }
                else
                {
                    Console.WriteLine("没有获取到锁");
                }
            }
            catch (Exception ex)
            {
                //吞掉异常
                //Console.WriteLine("Exception");
            }
        }
    }
}