
    SpKg                         S SK r S SKrS SKrS SKJr  S SKrS SKJr  \R                  " 5       r	S\
S\
S\
4S jrS\R                  4S	 jrg)
    N)NewMarketBot)loggerall_sessionswebshare_ipsreturnc                     / n[        S5       H^  n[        R                  " [        [        UU 4S9nSUl        S[        U5      -   Ul        UR                  5         UR                  U5        M`     U$ )N   )targetargsThandleListingsQueue)
range	threadingThreadr   listings_queuedaemonstrnamestartappend)r   r   handle_listings_queue_threadsits        $/var/www/highfloat_scraper/Queues.pystartHandleListingsQueuer   
   so    $&!2Y&
 &Q/		%,,Q/  )(    r   c                 j    U R                  5       S::  a,  [        R                  " [        R                  " SS5      5        OqU R                  5       S   n[        US   R                  5       5      S   S   n[        [        U5      SUU[        R                  " 5       5      nUR                  U5        M  )Nr   g?g?high_lowzBest Thread)qsizetimesleeprandomuniformgetlistvaluesr   r   queueQueuegetBestOrWorstSkinsBulk)r   r   r   	bulk_listr   nms         r   r   r      s    
!Q&JJv~~c3/0 '**,Q/I IaL//1215jAHHB &&y1! r   )r   r&   r!   newMarketBotr   r   LoggingFormatterr   r'   r   r$   r   r    r   r   <module>r.      sL       %  #)4 )t ) )$2 2r   