
    e%                     >    d dl Z d dlmZ d dlmZ d Zd Zd Zd ZdS )    N)ThreadPoolExecutor)statec                  ~    dgfd} t          j        d|           dk    sJ t          j        d|           dk    sJ d S )Nr   c                 2    | dxx         dz  cc<   | d         S Nr       is    9lib/python3.11/site-packages/panel/tests/io/test_state.pytest_fnz(test_as_cached_key_only.<locals>.test_fn	        	!	t    testr   r   	as_cachedr   s    r   test_as_cached_key_onlyr      s]    #     ?67++q0000?67++q000000r   c                  4   dgfd} t          j        d| d          dk    sJ t          j        d| d          dk    sJ t          j        d| d          dk    sJ t          j        d| d          dk    sJ t          j        d| d          dk    sJ d S )Nr   c                 2    |dxx         dz  cc<   |d         S r   r	   )ar   s     r   r   z-test_as_cached_key_and_kwarg.<locals>.test_fn   r   r   r   r   )r      r   r   s    r   test_as_cached_key_and_kwargr      s    S     ?67a000A5555?67a000A5555?67a000A5555?67a000A5555?67a000A555555r   c                  ^   dgfd} g }t          d          5 }t          d          D ]8}|                    t          j        d|           }|                    |           9	 d d d            n# 1 swxY w Y   d |D             g dk    sJ t          t          j                  dk    sJ d S )	Nr   c                 Z    | dxx         dz  cc<   t          j        d           | d         S )Nr   r   皙?)timesleepr
   s    r   r   z,test_as_cached_thread_locks.<locals>.test_fn   s-    	!	
3tr      )max_workersr   c                 6    g | ]}|                                 S r	   )result).0rs     r   
<listcomp>z/test_as_cached_thread_locks.<locals>.<listcomp>&   s     (((1AHHJJ(((r   )r   r   r   r   r   )r   rangesubmitr   r   appendlen_cache_locks)r   resultsexecutor_futures        r   test_as_cached_thread_locksr/      s   #    
 G		*	*	* #hq 	# 	#A__U_fgFFFNN6""""	## # # # # # # # # # # # # # # )((((LLL8888u!""a''''''s   A	A//A36A3c                      dgfd} t          j        d| d          dk    sJ t          j        d           t          j        d| d          dk    sJ d S )	Nr   c                 2    | dxx         dz  cc<   | d         S r   r	   r
   s    r   r   z#test_as_cached_ttl.<locals>.test_fn*   r   r   r   r   )ttlr   g)\(?r   )r   r   r   r   r   s    r   test_as_cached_ttlr3   )   sw    #     ?674449999Jt?67444999999r   )	r   concurrent.futuresr   panel.io.stater   r   r   r/   r3   r	   r   r   <module>r6      sx     1 1 1 1 1 1            1 1 1	6 	6 	6( ( (: : : : :r   