FilesExpand file tree

 patch-2

/

thread_lock4.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

53 lines (45 loc) · 1.12 KB

 patch-2

/

thread_lock4.py

Copy path

Top

File metadata and controls

• Code
• Blame

53 lines (45 loc) · 1.12 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

43

44

45

46

47

48

49

50

51

52

53

# test using lock to coordinate access to global mutable objects

#

# SPDX-FileCopyrightText: Copyright (c) 2016 Damien P. George on behalf of Pycom Ltd

#

# SPDX-License-Identifier: MIT

try:

import utime as time

except ImportError:

import time

import _thread

def fac(n):

x = 1

for i in range(1, n + 1):

x *= i

return x

def thread_entry():

while True:

with jobs_lock:

try:

f, arg = jobs.pop(0)

except IndexError:

return

ans = f(arg)

with output_lock:

output.append((arg, ans))

# create a list of jobs

jobs = [(fac, i) for i in range(20, 80)]

jobs_lock = _thread.allocate_lock()

n_jobs = len(jobs)

# create a list to store the results

output = []

output_lock = _thread.allocate_lock()

# spawn threads to do the jobs

for i in range(4):

_thread.start_new_thread(thread_entry, ())

# wait for the jobs to complete

while True:

with jobs_lock:

if len(output) == n_jobs:

break

time.sleep(1)

# sort and print the results

output.sort(key=lambda x: x[0])

for arg, ans in output:

print(arg, ans)