F/Orm/LINQS/ThreadSafeCache.cs

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

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

#region Copyright (c) 2008 by Jahmani Muigai Mwaura and Community
/*--------------------------------------------------------------------------------------------------
 *  LinqToSql, a Linq to Sql parser for the .NET Platform
 *  by Jahmani Mwaura and community
 *  ------------------------------------------------------------------------------------------------
 *  Version: LGPL 2.1
 *  
 *  Software distributed under the License is distributed on an "AS IS" basis,
 *  WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
 *  for the specific language governing rights and limitations under the
 *  License.
 *  
 *  The Original Code is any part of this file that is not marked as a contribution.
 *  
 *  The Initial Developer of the Original Code is Jahmani Muigai Mwaura.
 *  Portions created by the Initial Developer are Copyright (C) 2008
 *  the Initial Developer. All Rights Reserved.
 *  
 *  Contributor(s): None.
 *--------------------------------------------------------------------------------------------------
 */
#endregion

using System;
using System.Collections.Generic;
using System.Threading;

namespace F.Orm.LINQS
{
    
    public class ThreadSafeCache<TKey, TValue> {

        private readonly Dictionary<TKey, TValue> theDictionary = new Dictionary<TKey, TValue>();
        private readonly ReaderWriterLock rwl = new ReaderWriterLock();
        private readonly TimeSpan readerLockTimeout = TimeSpan.FromSeconds(1);
        private readonly TimeSpan writerLockTimeout = TimeSpan.FromSeconds(2);

        public ThreadSafeCache() {
        }

        public TValue this[TKey key] {
            get {
                try {
                    rwl.AcquireReaderLock(readerLockTimeout);
                    return theDictionary[key];
                }
                finally {
                    rwl.ReleaseReaderLock();
                }
            }
        }

        public ICollection<TKey> Keys {
            get {
                try {
                    rwl.AcquireReaderLock(readerLockTimeout);
                    return theDictionary.Keys;
                }
                finally {
                    rwl.ReleaseReaderLock();