aaa

    print(f"Starting {threads} threads")
    for i in range(0, threads):
        t = Thread(target=bucket_worker)
        t.daemon = True
        t.start()

    print(f"Done with everything in main thread. Waiting...")

    bucket_q.join()


if __name__ == "__main__":
    signal.signal(signal.SIGTSTP, signal_handler)
    main()