python:多线程:self作为全局变量

Question

我对python的多线程有一些问题：生成一个线程时，它会得到一些参数，比如线程名称、计数器等等。在线程的"run"部分，它正在调用一些子函数（还有一些深度的子函数）。然而，自变量（类）似乎不存在于子函数中：引用self.name会显示一些错误（NameError:未定义全局名称"self")。有没有任何方法可以在不（！！）参数化所有内容的情况下获得这些子函数中完整结构的内容（这将在深度4处变得非常长…）。希望这个简短的例子能更好地解释它，在sub1中，第二行打印尝试访问self-counter

#!/usr/bin/python
import threading
import time
globalVar = 1;
def sub1  ( name ):
  global globalVar ;
  print str(globalVar) + " in der 1. subfunktion von " +str(name)
  print "teste self"  + str(self.counter) + " - " + globalVar + " " +str(name) ;
  globalVar += 1 ;
  time.sleep(1);
  sub2 (name) ;
  return None ;

class 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 "Starting " + self.name + " mit zaehler " + str(self.counter)
        sub1 (self.name);
threadLock = threading.Lock()
threads = [] ;
# Create new threads
count =0;
while count < 10 :
        count += 1;
        threadX = myThread(count, "Thread-" + str(count), count)
        threadX.start()
        threads.append(threadX)
for t in threads:
    t.join()
print "Exiting Main Thread"

感谢您的帮助

Answer 1

为什么不简单地传递self而不是name？

#!/usr/bin/python
import threading
import time
globalVar = 1;
def sub1  ( self ):
  global globalVar ;
  print str(globalVar) + " in der 1. subfunktion von " +str(self.name)
  print "teste self"  + str(self.counter) + " - " + str(globalVar) + " " +str(self.name) ;
  globalVar += 1 ;
  time.sleep(1);
  sub2 (self.name) ;
  return None ;

class 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 "Starting " + self.name + " mit zaehler " + str(self.counter)
        sub1 (self);
threadLock = threading.Lock()
threads = [] ;
# Create new threads
count =0;
while count < 10 :
        count += 1;
        threadX = myThread(count, "Thread-" + str(count), count)
        threadX.start()
        threads.append(threadX)
for t in threads:
    t.join()
print "Exiting Main Thread"

由于int不能与string连接，我在sub1方法中将globalVar替换为str(globalVar)

工作如下：

>>> ================================ RESTART ================================
>>> 
Starting Thread-1 mit zaehler 1
1 in der 1. subfunktion von Thread-1
teste self1 - 1 Thread-1
Starting Thread-2 mit zaehler 2
2 in der 1. subfunktion von Thread-2
teste self2 - 2 Thread-2Starting Thread-3 mit zaehler 3
 Starting Thread-5 mit zaehler 5
Starting Thread-6 mit zaehler 6Starting Thread-7 mit zaehler 7Starting Thread-4 mit zaehler 4Starting Thread-8 mit zaehler 8Starting Thread-9 mit zaehler 9
 3 in der 1. subfunktion von Thread-3


3 in der 1. subfunktion von Thread-5Starting Thread-10 mit zaehler 10
3 in der 1. subfunktion von Thread-63 in der 1. subfunktion von Thread-73 in der 1. subfunktion von Thread-9
teste self3 - 3 Thread-3
3 in der 1. subfunktion von Thread-43 in der 1. subfunktion von Thread-8

teste self5 - 3 Thread-5
teste self7 - 3 Thread-7
3 in der 1. subfunktion von Thread-10teste self6 - 3 Thread-6teste self9 - 3 Thread-9
teste self4 - 4 Thread-4
teste self8 - 5 Thread-8
teste self10 - 6 Thread-10

//+ A bunch of Sub2 is not defined errors ...

Answer 2

sub1不是"子函数"。Python有"嵌套"函数，但这不是一个例子。"sub1"有一个完全不同的作用域，在你的类下看不到任何变量。

如果你想访问类实例（self）变量和方法，你应该将"self"作为参数传递给sub1，而不是self.name，它只是字符串"Thread-#"

def sub1(thread_instance):
    print thread_instance.name, thread_instance.threadID

然后在你的"run"方法中，用self:调用它

def run(self):
    sub1(self)

不要在线程中使用全局变量来存储线程中的对象，因为当多个线程读写该变量时，这肯定会引起麻烦。

此外，如果类中的threadID和counter参数都是同一个，那么它们的意义何在？此外，你的代码示例是不完整的，并且缺少代码，这使得你很难理解你试图用它实现什么以及你试图做什么

另一件事是，你不需要在每一行后面都有分号，这不是C。我会先多了解一下Python语言，在使用线程之前先了解一些基础知识。