首页 > 技术文章 > 缓存

liyangLife 2016-04-21 16:13 原文

 public abstract class SessionHandler<T> : IDisposable
        where T : new()
    {
        /// <summary>
        /// 缓存更新线程
        /// </summary>
        Thread SessionThread;

        /// <summary>
        /// 最后更新时间
        /// </summary>
        public DateTime LastModified { get; protected set; }

        /// <summary>
        /// 同步锁
        /// </summary>
        protected object Lock = new object();

        /// <summary>
        /// 缓存集合
        /// </summary>
        protected List<T> _session;

        /// <summary>
        /// 只读集合
        /// </summary>
        public IQueryable<T> Session
        {
            get
            {
                if (_session == null) return null;
                lock (Lock)
                {
                    return _session.AsQueryable<T>();
                }
            }
        }

        /// <summary>
        /// 数据库数据
        /// </summary>
        public abstract IQueryable<T> Database { get; }

        /// <summary>
        /// 加载缓存
        /// </summary>
        protected abstract void LoadSession();

        /// <summary>
        /// 线程开始时间
        /// </summary>
        /// <param name="sleep">休眠时间</param>
        protected void StartSessionThread(int sleep)
        {
            SessionThread = new Thread(() =>
            {
                while (true)
                {
                    Thread.Sleep(sleep);
                    LoadSession();
                }
            });
            SessionThread.Start();
        }

        /// <summary>
        /// 初始化
        /// </summary>
        public virtual void Init()
        {
            LastModified = DateTime.MaxValue;
            LoadSession();
            StartSessionThread(1800000);
        }

        private bool Disposed;

        public void Dispose()
        {
            if (SessionThread != null)
            {
                SessionThread.Abort();
            }
            GC.SuppressFinalize(this);
        }
    }

  

推荐阅读