fastCSharp/sql/cache/counter/counter.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using System.Threading;
using fastCSharp.setup.cSharp;

namespace fastCSharp.sql.cache.counter
{
    /// <summary>
    /// 缓存计数器
    /// </summary>
    /// <typeparam name="valueType">表格绑定类型</typeparam>
    /// <typeparam name="memberType">数据成员类型</typeparam>
    /// <typeparam name="keyType">关键字类型</typeparam>
    public abstract class counter<valueType, memberType, keyType> : copy<valueType, memberType>
        where valueType : class
        where memberType : IMemberMap<memberType>
        where keyType : IEquatable<keyType>
    {
        /// <summary>
        /// 缓存关键字获取器
        /// </summary>
        internal func<valueType, keyType> GetKey { get; private set; }
        /// <summary>
        /// 缓存数据
        /// </summary>
        private Dictionary<keyType, keyValue<valueType, int>> values;
        /// <summary>
        /// 获取缓存值
        /// </summary>
        /// <param name="key">关键字</param>
        /// <returns>缓存值</returns>
        public valueType this[keyType key]
        {
            get
            {
                return Get(key);
            }
        }
        /// <summary>
        /// 缓存计数
        /// </summary>
        /// <param name="sqlTool">SQL操作工具</param>
        /// <param name="getKey">缓存关键字获取器</param>
        /// <param name="memberMap">数据成员位图</param>
        protected counter(sqlTable.sqlToolBase<valueType, memberType> sqlTool, memberType memberMap, func<valueType, keyType> getKey)
            : base(sqlTool, memberMap)
        {
            if (getKey == null) log.Default.Throw(log.exceptionType.Null);
            GetKey = getKey;
            values = new Dictionary<keyType, keyValue<valueType, int>>();

            //sqlTool.OnUpdatedByIdentityLock += onUpdated;
            sqlTool.OnUpdatedLock += onUpdated;
            sqlTool.OnDeletedLock += onDeleted;
        }
        /// <summary>
        /// 更新记录事件
        /// </summary>
        public event action<valueType, valueType, valueType> OnUpdated;
        /// <summary>