|
2 | 2 | using BitFaster.Caching.Lru; |
3 | 3 | using System; |
4 | 4 | using System.Collections.Generic; |
5 | | -using System.Threading.Tasks; |
6 | 5 | using Xunit; |
7 | 6 | using System.Runtime.InteropServices; |
8 | | -using System.Threading; |
9 | 7 |
|
10 | 8 | namespace BitFaster.Caching.UnitTests.Lru |
11 | 9 | { |
@@ -166,6 +164,45 @@ public void WhenItemsAreExpiredExpireRemovesExpiredItems() |
166 | 164 | ); |
167 | 165 | } |
168 | 166 |
|
| 167 | + [Fact] |
| 168 | + public void WhenExpiredItemsAreTrimmedCacheMarkedCold() |
| 169 | + { |
| 170 | + Timed.Execute( |
| 171 | + lru, |
| 172 | + lru => |
| 173 | + { |
| 174 | + lru.AddOrUpdate(1, "1"); |
| 175 | + lru.AddOrUpdate(2, "2"); |
| 176 | + lru.AddOrUpdate(3, "3"); |
| 177 | + lru.GetOrAdd(1, valueFactory.Create); |
| 178 | + lru.GetOrAdd(2, valueFactory.Create); |
| 179 | + lru.GetOrAdd(3, valueFactory.Create); |
| 180 | + |
| 181 | + lru.AddOrUpdate(4, "4"); |
| 182 | + lru.AddOrUpdate(5, "5"); |
| 183 | + lru.AddOrUpdate(6, "6"); |
| 184 | + |
| 185 | + lru.AddOrUpdate(7, "7"); |
| 186 | + lru.AddOrUpdate(8, "8"); |
| 187 | + lru.AddOrUpdate(9, "9"); |
| 188 | + |
| 189 | + return lru; |
| 190 | + }, |
| 191 | + timeToLive.MultiplyBy(ttlWaitMlutiplier), |
| 192 | + lru => |
| 193 | + { |
| 194 | + lru.Policy.ExpireAfterWrite.Value.TrimExpired(); |
| 195 | + |
| 196 | + for (int i = 0; i < lru.Policy.Eviction.Value.Capacity; i++) |
| 197 | + { |
| 198 | + lru.GetOrAdd(i, k => k.ToString()); |
| 199 | + } |
| 200 | + |
| 201 | + lru.Count.Should().Be(lru.Policy.Eviction.Value.Capacity); |
| 202 | + } |
| 203 | + ); |
| 204 | + } |
| 205 | + |
169 | 206 | [Fact] |
170 | 207 | public void WhenCacheHasExpiredAndFreshItemsExpireRemovesOnlyExpiredItems() |
171 | 208 | { |
|
0 commit comments