o svXj1@sddlmZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddl m Z ddl mZmZmZddlmZmZmZmZmZmZdd lmZgd ZGd d d eZeZGd ddeZGdddeZGdddeZ dS))absolute_importN) connection)context) get_errno) monotonicEmptyFull)debugerrorinfoFinalizeregister_after_fork is_exiting)ForkingPickler)Queue SimpleQueue JoinableQueuec@seZdZdZd)ddZddZddZd d Zd*d dZd*ddZ ddZ ddZ ddZ ddZ ddZddZddZdd Zd!d"Zed#d$Zed%d&Zed'd(Zd S)+rz4 Queue type using a pipe, buffer and thread rcOsz|d}Wn tytdw|dkrddlm}||_tjdd\|_|_| |_ t |_ tjdkrr|rrrcompatrfiverrr utilr r r r rr reductionr__all__objectrrrrrr1r1r1r2s(      x32