require threads;
import threads;
require Thread::Queue;
import Thread::Queue;
import threads::shared;
share(\$CONNECT);