python 类变量 在多线程下的共享与开释题目
添加时间:2013-7-1 点击量:
比来被多线程给坑了下，没意识到类变量在多线程下是共享的，还有一个就是没意识到 内存开释题目，导致越累越大
1.python 类变量 在多线程景象 下的 是共享的
2.python 类变量 在多线程景象 下的 开释是不完全的
3.python 类变量 在多线程景象 下没开释的那项目组 内存 是可以反复哄骗的
1 import threading
2 import time
3
4 class Test:
5
6 cache = {}
7
8 ＠classmethod
9 def get_value（self， key）:
10 value = Test.cache.get（key， []）
11 return len（value）
12
13 ＠classmethod
14 def store_value（self， key， value）:
15 if not Test.cache.has_key（key）:
16 Test.cache[key] = range（value）
17 else:
18 Test.cache[key].extend（range（value））
19 return len（Test.cache[key]）
20
21 ＠classmethod
22 def release_value（self， key）:
23 if Test.cache.has_key（key）:
24 Test.cache.pop（key）
25 return True
26
27 ＠classmethod
28 def print_cache（self）:
29 print print_cache:
30 for key in Test.cache:
31 print key: ％d， value:％d ％ （key， len（Test.cache[key]））
32
33 def worker（number， value）:
34 key = number ％ 5
35 print threading: ％d， store_value: ％d ％ （number， Test.store_value（key， value））
36 time.sleep（10）
37 print threading: ％d， release_value: ％s ％ （number， Test.release_value（key））
38
39 if __name__ == __main__:
40 thread_num = 10
41
42 thread_pool = []
43 for i in range（thread_num）:
44 th = threading.Thread（target=worker，args=[i， 1000000]）
45 thread_pool.append（th）
46 thread_pool[i].start（）
47
48 for thread in thread_pool:
49 threading.Thread.join（thread）
50
51 Test.print_cache（）
52 time.sleep（10）
53
54 thread_pool = []
55 for i in range（thread_num）:
56 th = threading.Thread（target=worker，args=[i， 100000]）
57 thread_pool.append（th）
58 thread_pool[i].start（）
59
60 for thread in thread_pool:
61 threading.Thread.join（thread）
62
63 Test.print_cache（）
64 time.sleep（10）
总结
公用的数据，除非是只读的，不然不要当类成员变量，一是会共享，二是不好开释。
读书，不要想着实用，更不要有功利心。读书只为了自身的修养。邂逅一本好书如同邂逅一位知己，邂逅一个完美之人。有时心生敬意，有时怦然心动。仿佛你心底埋藏多年的话，作者替你说了出来，你们在时光深处倾心相遇的一瞬间，情投意合，心旷神怡。
比来被多线程给坑了下，没意识到类变量在多线程下是共享的，还有一个就是没意识到 内存开释题目，导致越累越大
1.python 类变量 在多线程景象 下的 是共享的
2.python 类变量 在多线程景象 下的 开释是不完全的
3.python 类变量 在多线程景象 下没开释的那项目组 内存 是可以反复哄骗的
1 import threading
2 import time
3
4 class Test:
5
6 cache = {}
7
8 ＠classmethod
9 def get_value（self， key）:
10 value = Test.cache.get（key， []）
11 return len（value）
12
13 ＠classmethod
14 def store_value（self， key， value）:
15 if not Test.cache.has_key（key）:
16 Test.cache[key] = range（value）
17 else:
18 Test.cache[key].extend（range（value））
19 return len（Test.cache[key]）
20
21 ＠classmethod
22 def release_value（self， key）:
23 if Test.cache.has_key（key）:
24 Test.cache.pop（key）
25 return True
26
27 ＠classmethod
28 def print_cache（self）:
29 print print_cache:
30 for key in Test.cache:
31 print key: ％d， value:％d ％ （key， len（Test.cache[key]））
32
33 def worker（number， value）:
34 key = number ％ 5
35 print threading: ％d， store_value: ％d ％ （number， Test.store_value（key， value））
36 time.sleep（10）
37 print threading: ％d， release_value: ％s ％ （number， Test.release_value（key））
38
39 if __name__ == __main__:
40 thread_num = 10
41
42 thread_pool = []
43 for i in range（thread_num）:
44 th = threading.Thread（target=worker，args=[i， 1000000]）
45 thread_pool.append（th）
46 thread_pool[i].start（）
47
48 for thread in thread_pool:
49 threading.Thread.join（thread）
50
51 Test.print_cache（）
52 time.sleep（10）
53
54 thread_pool = []
55 for i in range（thread_num）:
56 th = threading.Thread（target=worker，args=[i， 100000]）
57 thread_pool.append（th）
58 thread_pool[i].start（）
59
60 for thread in thread_pool:
61 threading.Thread.join（thread）
62
63 Test.print_cache（）
64 time.sleep（10）
总结
公用的数据，除非是只读的，不然不要当类成员变量，一是会共享，二是不好开释。
读书，不要想着实用，更不要有功利心。读书只为了自身的修养。邂逅一本好书如同邂逅一位知己，邂逅一个完美之人。有时心生敬意，有时怦然心动。仿佛你心底埋藏多年的话，作者替你说了出来，你们在时光深处倾心相遇的一瞬间，情投意合，心旷神怡。
