g dZddlmZGddeZGddeZGddeZGd d eZGd d eZd S)z This module contains multithread-safe cache implementations. All Caches have getorbuild(key, builder) delentry(key) methods and allow configuration when instantiating the cache class. )timec<eZdZd dZdZdZdZd dZdZd Z d S) BasicCachecV||_t||dz z |_i|_dS)N) maxentriesintprunenum_dict)selfr s H/granary/edev/quantum/lib/python3.11/site-packages/py/_path/cacheutil.py__init__zBasicCache.__init__s,$JA566  c8|jdSN)r clearr s rrzBasicCache.clears rc|j|Sr)r )r keys r _getentryzBasicCache._getentrysz#rcB|||j|<dSr)_prunelowestweightr r rentrys r _putentryzBasicCache._putentrys# !!! 3rFc@ |j|=dS#t$r|rYdSwxYwr)r KeyError)r rraisings rdelentryzBasicCache.delentrysI  3        s  c ||}n<#t$r/|||}|||YnwxYw|jSr)rr_buildrvalue)r rbuilderrs r getorbuildzBasicCache.getorbuild$sl 'NN3''EE ' ' 'KKW--E NN3 & & & & & '{s6AAc(t|j}||jkrnd|jD}|||jz }|dkr)|d|D] \}}||ddSdSdS)z' prune out entries with lowest weight. c&g|]\}}|j|fS)weight).0rrs r z1BasicCache._prunelowestweight..1s3>>>&ClC(>>>rrNF)r)lenr r itemssortr r )r numentriesr-indexr)rs rrzBasicCache._prunelowestweight,s__  ( (>>*.**:*:*<*<>>>E JJLLL.Eqyy#(%=66KFCMM#uM5555 ) ( y66rN)r)F) __name__ __module__ __qualname__rrrrr r%rr(rrrr s     6 6 6 6 6rrceZdZdZdZdS)BuildcostAccessCachea A BuildTime/Access-counting cache implementation. the weight of a value is computed as the product of num-accesses-of-a-value * time-to-build-the-value The values with the least such weights are evicted if the cache maxentries threshold is superceded. For implementation flexibility more than one object might be evicted at a time. ctt}|}t}t|||z Sr)gettimeWeightedCountingEntry)r rr$startvalends rr"zBuildcostAccessCache._buildGs3 giiii$S#e)444rN)r1r2r3__doc__r"r(rrr5r5:s-  55555rr5c0eZdZdZdZeeZdS)r8c0||_|x|_|_dSr)_valuer) _oneweight)r r# oneweights rrzWeightedCountingEntry.__init__Os (11 dooorc:|xj|jz c_|jSr)r)r@r?rs rr#zWeightedCountingEntry.valueSs t& {rN)r1r2r3rr#propertyr(rrr8r8Ns;222 HUOOEEErr8c0eZdZdZdfd ZdZdZxZS) AgingCachez; This cache prunes out cache entries that are too old. r$@cftt||||_dSr)superrEr maxseconds)r r rI __class__s rrzAgingCache.__init__[s, j$((444$rc|j|}|r$||t||Sr)r isexpiredr rrs rrzAgingCache._getentry_sB 3 ??   MM#   3--  rcb|}t|t|jz}|Sr) AgingEntryr7rI)r rr$r:rs rr"zAgingCache._buildfs,gii3 DO ;<< r)rrF)r1r2r3r<rrr" __classcell__)rJs@rrErEXse%%%%%%rrEceZdZdZdZdS)rNc"||_||_dSr)r#r))r r#expirationtimes rrzAgingEntry.__init__ls $ rc4t}||jkSr)r7r))r ts rrLzAgingEntry.isexpiredps IIDKrN)r1r2r3rrLr(rrrNrNks2%%%     rrNN) r<rr7objectrr5r8rErNr(rrrVs  ! +6+6+6+6+6+6+6+6Z55555:555(F&          r