.`iBddlZGddZGddZdS)Nc>eZdZddeddffd ZdefdZd dZxZS) CounterrstartreturnNcVt||_dSN)super__init__counter)selfr __class__s f/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/vllm/utils/counter.pyr zCounter.__init__s$  c4|j}|xjdz c_|S)Nr )r is r__next__zCounter.__next__ s L  rcd|_dS)Nrrr s rresetz Counter.resets  rr)rN)__name__ __module__ __qualname__intr rr __classcell__r s@rrrsc$ # rrcneZdZdZd deddffd ZedefdZd d edefd Zd d edefd Z xZ S) AtomicCounterzAn atomic, thread-safe counterrinitialrNct||_tj|_dS)z6Initialize a new atomic counter to given initial valueN)r r _value threadingLock_lock)r r!r s rr zAtomicCounter.__init__s3  ^%% rc|jSr)r#rs rvaluezAtomicCounter.values {rrnumcr|j5|xj|z c_|jcdddS#1swxYwYdS)z@Atomically increment the counter by num and return the new valueNr&r#r r)s rinczAtomicCounter.inc# Z   KK3 KK;                   ,00cr|j5|xj|zc_|jcdddS#1swxYwYdS)z@Atomically decrement the counter by num and return the new valueNr+r,s rdeczAtomicCounter.dec)r.r/r)r) rrr__doc__rr propertyr(r-r1rrs@rr r s((&&&D&&&&&&sXs3 s3rr )r$rr rrr5sm        r