from threading import Thread
import time
#
a = -1
b = 2
#
def task(arg):
global a
a = arg
time.sleep(2)
print(a)
# #
for i in range(10):
t = Thread(target=task, args=(i,))
t.start()
from threading import Thread from threading import local import time
""" {'线程1':{'value':1},'线程2':{'value':1},'线程3':{'value':1},'线程4':{'value':1},'线程5':{'value':1}}
""" from threading import get_ident
特殊的对象
lqz = local()
def task(arg):
# 对象.val = 1/2/3/4/5
lqz.value = arg
time.sleep(2)
print(lqz.value)
for i in range(10):
t = Thread(target=task,args=(i,))
t.start()
"""
local对象只支持线程，不支持协程，生成自己的local对象，各改个的，互补影响 {'线程1':{'value':1},'线程2':{'value':1},'线程3':{'value':1},'线程4':{'value':1},'线程5':{'value':1}}
"""
面向过程写法
from threading import get_ident,Thread,current_thread
import time
storage = {}
def set(k,v):
# 获取线程id
ident = get_ident()
if ident in storage:
storage
else:
storage[ident] = {k:v}
def get(k):
ident = get_ident()
return storage
def task(arg):
set('val',arg)
v = get('val')
print(v)
#
for i in range(10):
t = Thread(target=task,args=(i,))
t.start()
面向对象写法
from threading import get_ident, Thread
import time
# #
class Local(object):
storage = {}
#
def set(self, k, v):
ident = get_ident()
if ident in Local.storage:
Local.storage
else:
Local.storage[ident] = {k: v}
#
def get(self, k):
ident = get_ident()
return Local.storage
# #
obj = Local()
# #
def task(arg):
obj.set('val', arg)
v = obj.get('val')
print(v)
# #
for i in range(10):
t = Thread(target=task, args=(i,))
t.start()
# #
from threading import get_ident, Thread
import time
# #
class Local(object):
storage = {}
#
def setattr(self, k, v):
ident = get_ident()
if ident in Local.storage:
Local.storage
else:
Local.storage[ident] = {k: v}
#
def getattr(self, k):
ident = get_ident()
return Local.storage
# #
obj = Local()
# # #
def task(arg):
# setattr
# getattr
obj.val = arg
print(obj.val)
# #
for i in range(10):
t = Thread(target=task, args=(i,))
t.start()
from threading import get_ident, Thread import time
#
class Local(object):
def init(self):
object.setattr(self, 'storage', {})
# self.setattr('storage', {})
#
def setattr(self, k, v):
ident = get_ident()
if ident in self.storage:
self.storage
else:
self.storage[ident] = {k: v}
#
def getattr(self, k):
ident = get_ident()
return self.storage
# #
obj = Local()
# #
def task(arg):
obj.val = arg
obj.xxx = arg
print(obj.val)
# #
for i in range(10):
t = Thread(target=task, args=(i,))
t.start()
try: # getcurrent 获取协程id from greenlet import getcurrent as get_ident except Exception as e: # from threading import get_ident
from threading import Thread import time
class Local(object): def init(self): object.setattr(self, 'storage', {})
def __setattr__(self, k, v):
ident = get_ident()
if ident in self.storage:
self.storage[ident][k] = v
else:
self.storage[ident] = {k: v}
def __getattr__(self, k):
ident = get_ident()
return self.storage[ident][k]
obj = Local()
def task(arg): obj.val = arg obj.xxx = arg print(obj.val)
for i in range(10): t = Thread(target=task, args=(i,))