ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

使用C#实现简易缓存基类

2020-11-23 21:04:58  阅读:141  来源: 互联网

标签:缓存 Span C# Lock Cache System item 基类 public


ICache接口

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace EasyIoT.Cache
{
    /// <summary>
    /// 缓存接口
    /// </summary>
    /// <typeparam name="T">缓存实体</typeparam>
    public interface ICache<T> : IList<T>, IQueryable<T>
    {

    }
}

CacheBase基类

using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace EasyIoT.Cache
{
    /// <summary>
    /// 缓存基类
    /// </summary>
    /// <typeparam name="T">缓存实体</typeparam>
    public abstract class CacheBase<T> : ICache<T>
    {
        protected List<T> Cache = new List<T>();

        protected ReaderWriterLock Lock = new ReaderWriterLock();

        protected TimeSpan Span = TimeSpan.FromMilliseconds(100);

        public virtual T this[int index]
        {
            get
            {
                Lock.AcquireReaderLock(Span);
                try
                {
                    return Cache[index];
                }
                finally
                {
                    Lock.ReleaseReaderLock();
                }
            }
            set
            {
                Lock.AcquireWriterLock(Span);
                try
                {
                    Cache[index] = value;
                }
                finally
                {
                    Lock.ReleaseWriterLock();
                }
            }
        }

        public virtual int Count
        {
            get
            {
                Lock.AcquireReaderLock(Span);
                try
                {
                    return Cache.Count;
                }
                finally
                {
                    Lock.ReleaseReaderLock();
                }
            }
        }

        public virtual bool IsReadOnly => false;

        public Expression Expression => Cache.AsQueryable().Expression;

        public Type ElementType => typeof(T);

        public IQueryProvider Provider => Cache.AsQueryable().Provider;

        public void Add(T item)
        {
            if (item != null)
            {
                Lock.AcquireWriterLock(Span);
                try
                {
                    Cache.Add(item);
                }
                finally
                {
                    Lock.ReleaseWriterLock();
                }
            }
            else
            {
                return;
            }
        }

        public void Clear()
        {
            Lock.AcquireWriterLock(Span);
            try
            {
                Cache.Clear();
            }
            finally
            {
                Lock.ReleaseWriterLock();
            }
        }

        public bool Contains(T item)
        {
            if (item != null)
            {
                Lock.AcquireReaderLock(Span);
                try
                {
                    return Cache.Contains(item);
                }
                finally
                {
                    Lock.ReleaseReaderLock();
                }
            }
            else
            {
                return false;
            }
        }

        public void CopyTo(T[] array, int arrayIndex)
        {
            if (array != null)
            {
                Lock.AcquireReaderLock(Span);
                try
                {
                    Cache.CopyTo(array, arrayIndex);
                }
                finally
                {
                    Lock.ReleaseReaderLock();
                }
            }
            else
            {
                return;
            }
        }

        public IEnumerator<T> GetEnumerator()
        {
            return GetEnumerator() as IEnumerator<T>;
        }

        public int IndexOf(T item)
        {
            if (item != null)
            {
                Lock.AcquireReaderLock(Span);
                try
                {
                    return Cache.IndexOf(item);
                }
                finally
                {
                    Lock.ReleaseReaderLock();
                }
            }
            else
            {
                return -1;
            }
        }

        public void Insert(int index, T item)
        {
            if (item != null)
            {
                Lock.AcquireWriterLock(Span);
                try
                {
                    Cache.Insert(index, item);
                }
                finally
                {
                    Lock.ReleaseWriterLock();
                }
            }
            else
            {
                return;
            }
        }

        public bool Remove(T item)
        {
            if (item != null)
            {
                Lock.AcquireWriterLock(Span);
                try
                {
                    return Cache.Remove(item);
                }
                finally
                {
                    Lock.ReleaseWriterLock();
                }
            }
            else
            {
                return false;
            }
        }

        public void RemoveAt(int index)
        {
            Lock.AcquireWriterLock(Span);
            try
            {
                Cache.RemoveAt(index);
            }
            finally
            {
                Lock.ReleaseWriterLock();
            }
        }

        IEnumerator IEnumerable.GetEnumerator()
        {
            Lock.AcquireReaderLock(Span);
            try
            {
                return Cache.GetEnumerator();
            }
            finally
            {
                Lock.ReleaseReaderLock();
            }
        }
    }
}

标签:缓存,Span,C#,Lock,Cache,System,item,基类,public
来源: https://www.cnblogs.com/liveornot/p/14026999.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有