
    j                     V    d dl mZ d dlZd dlZd dlZdZdZd Zd Z	e
dk(  r e	        yy)    )ThreadPoolExecutorN<   
   c                 L    t        j                  | g      j                          y )N)paarray	to_pandas)is    K/tmp/pip-target-jj7clzyk/lib/python/pyarrow/tests/pandas_threaded_import.pythread_funcr      s    HHaSM    c            	      ,   t        j                  t        d       t        t              5 } dt
        j                  vsJ t        | j                  t        t        t                           dt
        j                  v sJ 	 d d d        y # 1 sw Y   y xY w)NT)exitpandas)faulthandlerdump_traceback_latertimeoutr   num_threadssysmoduleslistmapr   range)pools    r   mainr   "   sm    %%gD9	K	( 'Ds{{***TXXk5#5673;;&&&' ' 's   AB

B__main__)concurrent.futuresr   r   r   pyarrowr   r   r   r   r   __name__ r   r   <module>r!      s;   ( 2  
 
' zF r   