Tạo Thread bởi sử dụng threading Module trong Python

Để triển khai một thread mới bởi sử dụng threading Module, bạn phải thực hiện:

• Định nghĩa một lớp con của lớp Thread.

• Ghi đè phương thức __init__(self [,args]) để bổ sung thêm các tham số.

• Sau đó, ghi đè phương thức run(self [,args]) để triển khai những gì thread cần thực hiện khi được bắt đầu.

Một khi bạn đã tạo lớp con Thread mới, bạn có thể tạo một instance của nó và sau đó bắt đầu một Thread bởi triệu hồi phương thức start().

Ví dụ

 import threading
import timeexitFlag = 0class myThread (threading.Thread):
    def __init__(self, threadID, name, counter):
        threading.Thread.__init__(self)
        self.threadID = threadID
        self.name = name
        self.counter = counter
    def run(self):
        print "Bat dau " + self.name
        print_time(self.name, self.counter, 5)
        print "Ket thuc " + self.namedef print_time(threadName, delay, counter):
    while counter:
        if exitFlag:
            threadName.exit()
        time.sleep(delay)
        print "%s: %s" % (threadName, time.ctime(time.time()))
        counter -= 1# Tao cac thread moi
thread1 = myThread(1, "Thread-1", 1)
thread2 = myThread(2, "Thread-2", 2)# Bat dau cac thread moi
thread1.start()
thread2.start()print "Ket thuc Main Thread"

Kết quả là:

Bat dau Thread-1
Bat dau Thread-2
Ket thuc Main Thread
Thread-1: Mon Nov 21 09:10:03 2015
Thread-1: Mon Nov 21 09:10:04 2015
Thread-2: Mon Nov 21 09:10:04 2015
Thread-1: Mon Nov 21 09:10:05 2015
Thread-1: Mon Nov 21 09:10:06 2015
Thread-2: Mon Nov 21 09:10:06 2015
Thread-1: Mon Nov 21 09:10:07 2015
Ket thuc Thread-1
Thread-2: Mon Nov 21 09:10:08 2015
Thread-2: Mon Nov 21 09:10:10 2015
Thread-2: Mon Nov 21 09:10:12 2015
Ket thuc Thread-2

Đồng bộ hóa các Thread trong Python

Python cung cấp threading Module, mà bao gồm một kỹ thuật locking cho phép bạn đồng bộ hóa các Thread một cách dễ dàng. Một lock mới được tạo bởi gọi phương thức Lock().

Phương thức acquire(blocking) của đối tượng lock mới này được sử dụng để ép các Thread chạy một cách đồng bộ. Tham số blocking tùy ý cho bạn khả năng điều khiển để xem một Thread có cần đợi để đạt được lock hay không.

Nếu tham số blocking được thiết lập là 0, tức là Thread ngay lập tức trả về một giá trị 0 nếu không thu được lock và trả về giá trị 1 nếu thu được lock. Nếu blocking được thiết lập là 1, thì Thread cần đợi cho đến khi lock được giải phóng.

Phương thức release() của đối tượng lock được sử dụng để giải phóng lock khi nó không cần nữa.

Ví dụ

 import threading
import timeclass myThread (threading.Thread):
    def __init__(self, threadID, name, counter):
        threading.Thread.__init__(self)
        self.threadID = threadID
        self.name = name
        self.counter = counter
    def run(self):
        print "Bat dau " + self.name
        # Lay lock de dong bo hoa cac thread
        threadLock.acquire()
        print_time(self.name, self.counter, 3)
        # Giai phong lock cho thread ke tiep
        threadLock.release()def print_time(threadName, delay, counter):
    while counter:
        time.sleep(delay)
        print "%s: %s" % (threadName, time.ctime(time.time()))
        counter -= 1threadLock = threading.Lock()
threads = []# Tao cac thread moi
thread1 = myThread(1, "Thread-1", 1)
thread2 = myThread(2, "Thread-2", 2)# Bat dau cac thread moi
thread1.start()
thread2.start()# Them cac thread vao list
threads.append(thread1)
threads.append(thread2)# Doi cho tat ca thread ket thuc
for t in threads:
    t.join()
print "Ket thuc Main Thread"

Kết quả là:

Bat dau Thread-1
Bat dau Thread-2
Thread-1: Mon Nov 21 09:11:28 2015
Thread-1: Mon Nov 21 09:11:29 2015
Thread-1: Mon Nov 21 09:11:30 2015
Thread-2: Mon Nov 21 09:11:32 2015
Thread-2: Mon Nov 21 09:11:34 2015
Thread-2: Mon Nov 21 09:11:36 2015
Ket thuc Main Thread

Queue Module: quyền ưu tiên đa luồng trong Python

Queue Module cho phép bạn tạo một đối tượng queue mới mà có thể giữ một số lượng item nào đó. Dưới đây là các phương thức:

• get(): Xóa và trả về một item từ queue.

• put(): Thêm một item tới một queue.

• qsize() : Trả về số item mà hiện tại đang trong queue.

• empty(): Trả về true nếu queue là trống, nếu không thì trả về false.

• full(): Trả về true nếu queue là đầy, nếu không thì trả về false.

Ví dụ

 import Queue
import threading
import timeexitFlag = 0class myThread (threading.Thread):
    def __init__(self, threadID, name, q):
        threading.Thread.__init__(self)
        self.threadID = threadID
        self.name = name
        self.q = q
    def run(self):
        print "Bat dau " + self.name
        process_data(self.name, self.q)
        print "Ket thuc " + self.namedef process_data(threadName, q):
    while not exitFlag:
        queueLock.acquire()
        if not workQueue.empty():
            data = q.get()
            queueLock.release()
            print "%s dang xu ly %s" % (threadName, data)
        else:
            queueLock.release()
        time.sleep(1)threadList = ["Thread-1", "Thread-2", "Thread-3"]
nameList = ["One", "Two", "Three", "Four", "Five"]
queueLock = threading.Lock()
workQueue = Queue.Queue(10)
threads = []
threadID = 1# Tao cac thread moi
for tName in threadList:
    thread = myThread(threadID, tName, workQueue)
    thread.start()
    threads.append(thread)
    threadID += 1# Dien vao queue
queueLock.acquire()
for word in nameList:
    workQueue.put(word)
queueLock.release()# Doi den khi queue la trong
while not workQueue.empty():
    pass# Thong bao cho thread do la thoi gian de ket thuc
exitFlag = 1# Doi cho tat ca thread ket thuc
for t in threads:
    t.join()
print "Ket thuc Main Thread"

Kết quả là:

Bat dau Thread-1
Bat dau Thread-2
Bat dau Thread-3
Thread-1 dang xu ly One
Thread-2 dang xu ly Two
Thread-3 dang xu ly Three
Thread-1 dang xu ly Four
Thread-2 dang xu ly Five
Ket thuc Thread-3
Ket thuc Thread-1
Ket thuc Thread-2
Ket thuc Main Thread