from multiprocessing import JoinableQueue as JQueue

# imagine this is the thread
def processor(in_queue):
    while True:
        item = in_queue.get()
        process(item)  # or whatever you do with it
        # now that we're done processing this item, let the queue know we've finished with this item
        in_queue.task_done()

queue = JQueue()
# create the thread here, passing (queue, ) as args so the thread has access to the queue

# now we can add things to the queue, and the thread will process them
queue.put("test thing")
queue.put("something else")

# then we just wait for the thread to finish processing everything we sent it
queue.join()

# at this point, we're in the main thread, the queue is empty, and everything that was in it has been fully processed