Python - 线程优先级

import threading
import time

class DummyThread(threading.Thread):
	 	def __init__(self, name, priority):
	 	 	 threading.Thread.__init__(self)
	 	 	 self.name = name
	 	 	 self.priority = priority

	 	def run(self):
	 	 	 name = self.name
	 	 	 time.sleep(1.0 * self.priority)
	 	 	 print(f"{name} thread with priority {self.priority} is running")

# Creating threads with different priorities
t1 = DummyThread(name='Thread-1', priority=4)
t2 = DummyThread(name='Thread-2', priority=1)

# Starting the threads
t1.start()
t2.start()

# Waiting for both threads to complete
t1.join()
t2.join()

print('All Threads are executed')

import threading
import ctypes
import time

# Constants for Windows API
w32 = ctypes.windll.kernel32
SET_THREAD = 0x20
PRIORITIZE_THE_THREAD = 1

class MyThread(threading.Thread):
	 	def __init__(self, start_event, name, iterations):
	 	 	 super().__init__()
	 	 	 self.start_event = start_event
	 	 	 self.thread_id = None
	 	 	 self.iterations = iterations
	 	 	 self.name = name

	 	def set_priority(self, priority):
	 	 	 if not self.is_alive():
	 	 	 	 	print('Cannot set priority for a non-active thread')
	 	 	 	 	return

	 	 	 thread_handle = w32.OpenThread(SET_THREAD, False, self.thread_id)
	 	 	 success = w32.SetThreadPriority(thread_handle, priority)
	 	 	 w32.CloseHandle(thread_handle)
	 	 	 if not success:
	 	 	 	 	print('Failed to set thread priority:', w32.GetLastError())

	 	def run(self):
	 	 	 self.thread_id = w32.GetCurrentThreadId()
	 	 	 self.start_event.wait()
	 	 	 while self.iterations:
	 	 	 	 	print(f"{self.name} running")
	 	 	 	 	start_time = time.time()
	 	 	 	 	while time.time() - start_time < 1:
	 	 	 	 	 	 pass
	 	 	 	 	self.iterations -= 1

# Create an event to synchronize thread start
start_event = threading.Event()

# Create threads
thread_normal = MyThread(start_event, name='normal', iterations=4)
thread_high = MyThread(start_event, name='high', iterations=4)

# Start the threads
thread_normal.start()
thread_high.start()

# Adjusting priority of 'high' thread
thread_high.set_priority(PRIORITIZE_THE_THREAD)

# Trigger thread execution
start_event.set()

 queue.PriorityQueue(maxsize=0)

 (priority_number, data)

from time import sleep
from random import random, randint
from threading import Thread
from queue import PriorityQueue

queue = PriorityQueue()

def producer(queue):
	 	print('Producer: Running')
	 	for i in range(5):

	 	 	 # create item with priority
	 	 	 value = random()
	 	 	 priority = randint(0, 5)
	 	 	 item = (priority, value)
	 	 	 queue.put(item)
	 	# wait for all items to be processed
	 	queue.join()

	 	queue.put(None)
	 	print('Producer: Done')

def consumer(queue):
	 	print('Consumer: Running')

	 	while True:

	 	 	 # get a unit of work
	 	 	 item = queue.get()
	 	 	 if item is None:
	 	 	 	 	break

	 	 	 sleep(item[1])
	 	 	 print(item)
	 	 	 queue.task_done()
	 	print('Consumer: Done')

producer = Thread(target=producer, args=(queue,))
producer.start()

consumer = Thread(target=consumer, args=(queue,))
consumer.start()

producer.join()
consumer.join()