|
Server : Apache System : Linux cvar2.toservers.com 3.10.0-962.3.2.lve1.5.73.el7.x86_64 #1 SMP Wed Aug 24 21:31:23 UTC 2022 x86_64 User : njnconst ( 1116) PHP Version : 8.4.18 Disable Function : NONE Directory : /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/ |
Upload File : |
� e�Tc @ sM d d l m Z d d l m Z d d d � � YZ d e f d � � YZ d S( i����( t Queue( t Threadt ThreadPoolc B s# e Z d � Z d � Z d � Z RS( c C s7 t | � | _ x! t | � D] } t | j � q Wd S( N( R t taskst ranget WorkerThread( t selft num_threadst _( ( sP /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/threadpool.pyt __init__ s c C s | j j � d S( s1 Wait for completion of all the tasks in the queueN( R t join( R ( ( sP /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/threadpool.pyt wait s c O s | j j | | | f � d S( s Add a task to the queueN( R t put( R t funct argst kargs( ( sP /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/threadpool.pyt add s ( t __name__t __module__R R R ( ( ( sP /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/threadpool.pyR s R c B s e Z d � Z d � Z RS( c C s- t j | � | | _ t | _ | j � d S( N( R R R t Truet daemont start( R R ( ( sP /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/threadpool.pyR % s c C sb x[ t r] | j j � \ } } } y | | | � Wn t k rL } | GHn X| j j � q Wd S( N( R R t gett Exceptiont task_done( R R R R t e( ( sP /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/threadpool.pyt run+ s ( R R R R ( ( ( sP /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/threadpool.pyR $ s N( ( R t threadingR R R ( ( ( sP /usr/lib/python2.7/site-packages/redhat_support_lib/infrastructure/threadpool.pyt <module> s