以下是一个使用优先级队列来解决并行作业任务的示例代码：

import queue
import threading

# 创建一个优先级队列
job_queue = queue.PriorityQueue()

# 定义一个工作类
class Job:
    def __init__(self, priority, description):
        self.priority = priority
        self.description = description

    # 定义比较方法，根据优先级进行比较
    def __lt__(self, other):
        return self.priority < other.priority

# 定义一个工作执行函数
def execute_job(job):
    print('Executing job:', job.description)

# 定义一个工作生产者函数
def producer():
    # 添加一些工作到队列中
    job_queue.put(Job(3, 'Job 3'))
    job_queue.put(Job(1, 'Job 1'))
    job_queue.put(Job(2, 'Job 2'))
    job_queue.put(Job(5, 'Job 5'))
    job_queue.put(Job(4, 'Job 4'))

# 定义一个工作消费者函数
def consumer():
    while True:
        # 从队列中获取一个工作
        job = job_queue.get()
        # 执行工作
        execute_job(job)
        # 标记工作已经完成
        job_queue.task_done()

# 创建一个工作生产者线程
producer_thread = threading.Thread(target=producer)
producer_thread.start()

# 创建多个工作消费者线程
consumer_threads = []
for i in range(3):
    consumer_thread = threading.Thread(target=consumer)
    consumer_threads.append(consumer_thread)
    consumer_thread.start()

# 等待所有工作完成
job_queue.join()

# 等待所有线程退出
producer_thread.join()
for consumer_thread in consumer_threads:
    consumer_thread.join()

在上面的示例中，我们使用Python的queue模块中的PriorityQueue类来创建一个优先级队列。首先，我们定义了一个Job类，它包含优先级和描述两个属性，并重写了小于运算符（lt）方法，以便根据优先级进行比较。然后，我们定义了一个execute_job函数，用于执行工作。接下来，我们定义了一个生产者函数producer，用于向队列中添加一些工作。最后，我们定义了一个消费者函数consumer，它不断地从优先级队列中取出工作并执行。

在主程序中，我们创建了一个工作生产者线程和多个工作消费者线程。生产者线程负责向队列中添加工作，消费者线程负责从队列中获取工作并执行。我们使用join方法来等待所有工作完成和所有线程退出。

这个示例代码展示了如何使用优先级队列来解决并行作业任务的问题，通过设置不同的优先级，可以控制不同工作的执行顺序。