@Override
    public void run() {
        try
        {
            while (!Thread.interrupted())
            {
                q.take().run();
            }
        } catch (InterruptedException e)
        {
        }
        System.out.println("Finished PrioritizedTaskConsumer");
    }