(phZ rSrSSKrSSKrSSKr"SS5r"SS\R R 5rg)zm The code is derived from https://github.com/althonos/pronto/commit/3384010dfb4fc7c66a219f59276adef3288a886b Nc<\rSrSrSrSSjrS Sjr\S5rSr g) SharedCounter aKA synchronized shared counter. The locking done by multiprocessing.Value ensures that only a single process or thread may read or write the in-memory ctypes object. However, in order to do n += 1, Python performs a read followed by a write, so a second process may read the old value before the new one is written by the first process. The solution is to use a multiprocessing.Lock to guarantee the atomicity of the modifications to Value. This class comes almost entirely from Eli Bendersky's blog: http://eli.thegreenplace.net/2012/01/04/shared-counter-with-pythons-multiprocessing/ c<[R"SU5Ulg)Ni)multiprocessingValuecountselfns B/var/www/html/venv/lib/python3.13/site-packages/django_q/queues.py__init__SharedCounter.__init__s$**32 cURR5 UR=RU- slSSS5 g!,(df  g=f)z(Increment the counter by n (default = 1)N)r get_lockvaluer s r incrementSharedCounter.increments3 ZZ " JJ   ! # " "s A Ac.URR$)zReturn the value of the counter)r rr s rrSharedCounter.value!szzr)r N)r)) __name__ __module__ __qualname____firstlineno____doc__rrpropertyr__static_attributes__rrrr s% 3"   rrcx^\rSrSrSrU4SjrU4SjrU4SjrU4SjrU4Sjr S\ 4S jr S\ 4S jr S rU=r$) Queue'aFA portable implementation of multiprocessing.Queue. Because of multithreading / multiprocessing semantics, Queue.qsize() may raise the NotImplementedError exception on Unix platforms like Mac OS X where sem_getvalue() is not implemented. This subclass addresses this problem by using a synchronized shared counter (initialized to zero) and increasing / decreasing its value every time the put() and get() methods are called, respectively. This not only prevents NotImplementedError from being raised, but also allows us to implement a reliable version of both qsize() and empty(). c>[RS:a[[U]"U0UD6 O)[[U]"US[ R "50UD6 [S5Ulg)N)rctxr) sys version_infosuperr$rr get_contextrsizer argskwargs __class__s rrQueue.__init__4s^   f $ % ' 8 8 % ' *668 [[U] 5UR4-$)N)r+r$ __getstate__r-)r r1s rr4Queue.__getstate__=sUD.0DII<??rcF>[[U] USS5 USUlgN)r+r$ __setstate__r-)r stater1s rr9Queue.__setstate__@s# eT'cr 3"I rcd>[[U] "U0UD6 URR S5 g)Nr)r+r$putr-rr.s rr= Queue.putDs) eT// Arcf>[[U] "U0UD6nURR S5 U$r7)r+r$getr-r)r r/r0xr1s rr@ Queue.getHs0 % "D 3F 3 Brreturnc.URR$)z8Reliable implementation of multiprocessing.Queue.qsize())r-rrs rqsize Queue.qsizeMsyyrc*UR5S:+$)z8Reliable implementation of multiprocessing.Queue.empty()r)rErs rempty Queue.emptyQs::rOs7    8,$O " " ( (,$r