Hướng dẫn python thread-safe variable - biến an toàn trong chuỗi python

Takeaways....

Một chủ đề là một chủ đề thực thi trong một chương trình máy tính.

lock=Lock()=Lock()=Lock()

Takeaways....

Một chủ đề là một chủ đề thực thi trong một chương trình máy tính.

lock.acquire().acquire().acquire()

Mỗi chương trình Python có ít nhất một luồng thực thi được gọi là luồng chính. Cả hai quy trình và luồng được tạo và quản lý bởi hệ điều hành cơ bản.

counter+=1+=1+=1

Đôi khi chúng ta có thể cần tạo các luồng bổ sung trong chương trình của chúng tôi để thực thi mã đồng thời.

lock.release().release().release()

Takeaways....

Một chủ đề là một chủ đề thực thi trong một chương trình máy tính.

Mỗi chương trình Python có ít nhất một luồng thực thi được gọi là luồng chính. Cả hai quy trình và luồng được tạo và quản lý bởi hệ điều hành cơ bản.lock:

Mỗi chương trình Python có ít nhất một luồng thực thi được gọi là luồng chính. Cả hai quy trình và luồng được tạo và quản lý bởi hệ điều hành cơ bản.

counter+=1+=1+=1

Một chủ đề là một chủ đề thực thi trong một chương trình máy tính.

classThreadUnsafeCounter():ThreadUnsafeCounter():ThreadUnsafeCounter():

Mỗi chương trình Python có ít nhất một luồng thực thi được gọi là luồng chính. Cả hai quy trình và luồng được tạo và quản lý bởi hệ điều hành cơ bản.

Python cung cấp khả năng tạo và quản lý các luồng mới thông qua mô -đun luồng và lớp luồng.threading.Thread class.

Bạn có thể tìm hiểu thêm về các chủ đề Python trong hướng dẫn:__init__(self):

Chủ đề trong Python: Hướng dẫn hoàn chỉnh# initialize counter

    self._counter=0self._counter=0self._counter=0

Điều này có thể là vì nhiều lý do, chẳng hạn như:

Đếm các nhiệm vụ hoàn thành bởi nhiều chủ đề công nhân.increment(self):

    self._counter+=1self._counter+=1self._counter+=1

Đếm sự xuất hiện của các sự kiện.

Cập nhật một biến số từ nhiều luồng không an toàn và có thể dẫn đến một điều kiện cuộc đua.value(self):value(self):

    returnself._counterreturnself._counterreturnself._counter

Một chủ đề là một chủ đề thực thi trong một chương trình máy tính.

classThreadUnsafeCounter():ThreadUnsafeCounter():ThreadUnsafeCounter():

Mỗi chương trình Python có ít nhất một luồng thực thi được gọi là luồng chính. Cả hai quy trình và luồng được tạo và quản lý bởi hệ điều hành cơ bản.# constructor# constructor

Đôi khi chúng ta có thể cần tạo các luồng bổ sung trong chương trình của chúng tôi để thực thi mã đồng thời.def __init__(self):def __init__(self):

Python cung cấp khả năng tạo và quản lý các luồng mới thông qua mô -đun luồng và lớp luồng.# initialize counter# initialize counter

        self._counter=0self._counter=0self._counter=0

Bạn có thể tìm hiểu thêm về các chủ đề Python trong hướng dẫn:# increment the counter# increment the counter

Chủ đề trong Python: Hướng dẫn hoàn chỉnhdef increment(self):def increment(self):

        self._counter+=1self._counter+=1self._counter+=1

Trong lập trình đồng thời, chúng ta thường cần cập nhật một bộ đếm từ nhiều luồng.# get the counter value# get the counter value

Điều này có thể là vì nhiều lý do, chẳng hạn như:def value(self):def value(self):

        returnself._counterreturnself._counterreturnself._counter

Đếm sự xuất hiện của các sự kiện.

Cập nhật một biến số từ nhiều luồng không an toàn và có thể dẫn đến một điều kiện cuộc đua.task(counter):task(counter):

Bạn có thể tìm hiểu thêm về các chủ đề Python trong hướng dẫn:# increment the counter# increment the counter

    for_inrange(100000):for_inrange(100000):for_inrange(100000):

        counter.increment()counter.increment()counter.increment()

Trong lập trình đồng thời, chúng ta thường cần cập nhật một bộ đếm từ nhiều luồng.# get the counter value..

Điều này có thể là vì nhiều lý do, chẳng hạn như:def value(self):

counter=ThreadUnsafeCounter()=ThreadUnsafeCounter()=ThreadUnsafeCounter()

Trong lập trình đồng thời, chúng ta thường cần cập nhật một bộ đếm từ nhiều luồng.# get the counter value..

Điều này có thể là vì nhiều lý do, chẳng hạn như:def value(self):

threads=[Thread(target=task,args=(counter,))for_inrange(10)]=[Thread(target=task,args=(counter,))for_inrange(10)]=[Thread(target=task,args=(counter,))for_ inrange(10)]

Trong lập trình đồng thời, chúng ta thường cần cập nhật một bộ đếm từ nhiều luồng.# get the counter value..

Điều này có thể là vì nhiều lý do, chẳng hạn như:def value(self):

Đếm các nhiệm vụ hoàn thành bởi nhiều chủ đề công nhân.thread inthreads:

    thread.start()thread.start()thread.start()

Đối chiếu các giá trị từ các nguồn dữ liệu khác nhau.

Đếm các nhiệm vụ hoàn thành bởi nhiều chủ đề công nhân.thread inthreads:

    thread.join()thread.join()thread.join()

Trong lập trình đồng thời, chúng ta thường cần cập nhật một bộ đếm từ nhiều luồng.# get the counter value..

Điều này có thể là vì nhiều lý do, chẳng hạn như:def value(self):

print(counter.value())(counter.value())(counter.value())

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

Đếm sự xuất hiện của các sự kiện.

Cập nhật một biến số từ nhiều luồng không an toàn và có thể dẫn đến một điều kiện cuộc đua.task(counter):

Chủ đề trong Python: Hướng dẫn hoàn chỉnhThreadUnsafeCounter to be shared among all threads.threading import Thread

.....

classThreadUnsafeCounter():ThreadUnsafeCounter():ThreadUnsafeCounter():

# Tạo bộ đếm# constructor

Sau đó, chúng ta có thể tạo 10 luồng sẽ được cấu hình để gọi hàm Task () này và chuyển thể hiện bộ đếm dưới dạng đối số.task() function and pass the counter instance as an argument.def __init__(self):

# Tạo 10 luồng để tăng bộ đếm# initialize counter

        self._counter=0self._counter=0self._counter=0

Tiếp theo, chúng ta có thể bắt đầu tất cả mười chủ đề và sau đó đợi chúng kết thúc.# increment the counter

# Bắt đầu tất cả các luồngdef increment(self):

        self._counter+=1self._counter+=1self._counter+=1

Inthreads forthreads:thread inthreads:# get the counter value

# Đợi tất cả các chủ đề kết thúcdef value(self):

        returnself._counterreturnself._counterreturnself._counter

Cuối cùng, chúng ta có thể báo cáo giá trị cuối cùng của bộ đếm.

# Báo cáo giá trị của bộ đếmtask(counter):

Tiếp theo, chúng ta có thể bắt đầu tất cả mười chủ đề và sau đó đợi chúng kết thúc.# increment the counter

    for_inrange(100000):for_inrange(100000):for_inrange(100000):

        counter.increment()counter.increment()counter.increment()

Điều này có thể là vì nhiều lý do, chẳng hạn như:def value(self):

counter=ThreadUnsafeCounter()=ThreadUnsafeCounter()=ThreadUnsafeCounter()

Điều này có thể là vì nhiều lý do, chẳng hạn như:def value(self):

threads=[Thread(target=task,args=(counter,))for_inrange(10)]=[Thread(target=task,args=(counter,))for_inrange(10)]= [Thread(target=task,args=(counter,))for_inrange(10)]

Điều này có thể là vì nhiều lý do, chẳng hạn như:def value(self):

Inthreads forthreads:thread inthreads:thread inthreads:

    thread.start()thread.start()thread.start()

# Đợi tất cả các chủ đề kết thúc

Inthreads forthreads:thread inthreads:thread inthreads:

    thread.join()thread.join()thread.join()

Cuối cùng, chúng ta có thể báo cáo giá trị cuối cùng của bộ đếm.

print(counter.value())(counter.value())(counter.value())

Cuối cùng, giá trị của bộ đếm được báo cáo.

Trong trường hợp này, chúng ta có thể thấy rằng bộ đếm không có giá trị mong đợi. Thay vào đó, nó là khoảng 280.000 so với giá trị 1.000.000 mà chúng tôi mong đợi.__init__(self):__init__(self):

Trong thực tế, mỗi khi chương trình được chạy, bạn sẽ thấy một giá trị khác nhau.# initialize counter# initialize counter

    self._counter=0self._counter=0self._counter=0

Điều này là do biến _Count được cập nhật theo cách không an toàn.# initialize lock# initialize lock

    self._lock=Lock()self._lock=Lock()self._lock=Lock()

Bạn có thể tìm hiểu thêm về loại điều kiện cuộc đua này ở đây:

Điều kiện cuộc đua với một biến được chia sẻ trong Pythonincrement(self):increment(self):

Tiếp theo, hãy để cập nhật lớp học của chúng tôi để an toàn chủ đề.with self._lock:with self._lock:

        self._counter+=1self._counter+=1self._counter+=1

Đăng ký khóa học email 7 ngày miễn phí của tôi và khám phá cách sử dụng mô-đun luồng Python, bao gồm cách tạo và bắt đầu các chủ đề mới, cách sử dụng Mutex và Semaphore, và nhiều hơn nữa!

Nhấp vào nút bên dưới và nhập địa chỉ email của bạn để đăng ký và nhận bài học đầu tiên ngay bây giờ.value(self):value(self):

Tiếp theo, hãy để cập nhật lớp học của chúng tôi để an toàn chủ đề.with self._lock:with self._lock:

        returnself._counterreturnself._counterreturnself._counter

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

Đăng ký khóa học email 7 ngày miễn phí của tôi và khám phá cách sử dụng mô-đun luồng Python, bao gồm cách tạo và bắt đầu các chủ đề mới, cách sử dụng Mutex và Semaphore, và nhiều hơn nữa!

classThreadSafeCounter():ThreadSafeCounter():ThreadSafeCounter():

Nhấp vào nút bên dưới và nhập địa chỉ email của bạn để đăng ký và nhận bài học đầu tiên ngay bây giờ.value(self):# constructor

Khóa học luồng python miễn phíThreadSafeCounter. The updated thread-safe version of the class is listed below.def __init__(self):

& nbsp; & nbsp; & nbsp; & nbsp;# Constructor# constructor# initialize counter

        self._counter=0self._counter=0self._counter=0

& nbsp; & nbsp; & nbsp; & nbsp; def __init __ (self):def __init__(self):# initialize lock

        self._lock=Lock()self._lock=Lock()self._lock=Lock()

& nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp;# khởi tạo bộ đếm# initialize counter# increment the counter

& nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp;# khởi tạo khóa# initialize lockdef increment(self):

& nbsp; & nbsp; & nbsp; & nbsp;# tăng bộ đếm# increment the counterwith self._lock:

            self._counter+=1self._counter+=1self._counter+=1

& nbsp; & nbsp; & nbsp; & nbsp; def tăng (self):def increment(self):# get the counter value

& nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp;with self._lock:def value(self):

& nbsp; & nbsp; & nbsp; & nbsp;# tăng bộ đếm# increment the counterwith self._lock:

            returnself._counterreturnself._counterreturnself._counter

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

Và ĐÓ Là Nó.

Buộc nào lại với nhau, ví dụ hoàn chỉnh được liệt kê dưới đây.

# SuperfastPython.comthreading Chủ đề nhậpthreading import Thread

# Ví dụ về bộ đunthreading import Lock

từ luồng NHập luồng

classThreadSafeCounter():ThreadSafeCounter():ThreadSafeCounter():

& nbsp; & nbsp; & nbsp; & nbsp;# Constructor# Constructor# constructor

& nbsp; & nbsp; & nbsp; & nbsp; def __init __ (self): def __init __ (tự):def __init__(self):

& nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp;# initialize counter

        self._counter=0self._counter=0self._counter=0

& nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp;# khởi tạo khào# khởi tạo khóa# initialize lock

        self._lock=Lock()self._lock=Lock()self._lock=Lock()

& nbsp; & nbsp; & nbsp; & nbsp;# increment the counter

& nbsp; & nbsp; & nbsp; & nbsp; def trot (self): def tăng (tự):def increment(self):

& nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; với self._lock:with self._lock:

            self._counter+=1self._counter+=1self._counter+=1

& nbsp; & nbsp; & nbsp; & nbsp;# get the counter value

& nbsp; & nbsp; & nbsp; & nbsp; giá trị def (tự): giá trị def (tự):def value(self):

& nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; với self._lock:with self._lock:

            returnself._counterreturnself._counterreturnself._counter

& nbsp; & nbsp; & nbsp; & nbsp;

& nbsp; & nbsp; & nbsp; & nbsp;task(counter):

& nbsp; & nbsp; & nbsp; & nbsp;# increment the counter

    for_inrange(100000):for_inrange(100000):for _inrange(100000):

        counter.increment()counter.increment()counter.increment()

& nbsp; & nbsp; & nbsp; & nbsp; def trot (self): def tăng (tự):

counter=ThreadSafeCounter()=ThreadSafeCounter()=ThreadSafeCounter()

& nbsp; & nbsp; & nbsp; & nbsp; & nbsp; & nbsp; với self._lock:

threads=[Thread(target=task,args=(counter,))for_inrange(10)]=[Thread(target=task,args=(counter,))for_inrange(10)]=[Thread(target=task,args=(counter,))for_inrange(10)]

& nbsp; & nbsp; & nbsp; & nbsp;

& nbsp; & nbsp; & nbsp; & nbsp;thread inthreads:

    thread.start()thread.start()thread.start()

Và ĐÓ Là Nó.

& nbsp; & nbsp; & nbsp; & nbsp;thread inthreads:

    thread.join()thread.join()thread.join()

Và ĐÓ Là Nó.

print(counter.value())(counter.value())(counter.value())