0

worker_manager を機能させようとしていますが、次のエラーが発生し続けます。

Traceback (most recent call last):
  File "multiQueue2.py", line 61, in <module>
    manager.generate(control, threadName, i)
  File "multiQueue2.py", line 38, in generate
    target = i.getattr(name)
AttributeError: 'int' object has no attribute 'getattr'

これが私が作業しているコードです。worker_manager は、ライブになる唯一の部分です。辞書からスレッド名を取得し、関連するクラスにアクセスすることになっています。アドバイスはありますか？ありがとう！

import multiprocessing 
import time 

class test_imports:#Test classes remove 
      def import_1(self, control_queue, thread_number):
          print ("Import_1 number %d started") % thread_number
          run = True
          count = 1
          while run:
                alive = control_queue.get()
                if alive == 't1kill':
                   print ("Killing thread type 1 number %d") % thread_number
                   run = False
                   break
                print ("Thread type 1 number %d run count %d") % (thread_number, count)
                count = count + 1

      def import_2(self, control_queue, thread_number):
          print ("Import_1 number %d started") % thread_number
          run = True
          count = 1
          while run:
                alive = control_queue.get()
                if alive == 't2kill':
                   print ("Killing thread type 2 number %d") % thread_number
                   run = False
                   break
                print ("Thread type 2 number %d run count %d") % (thread_number, count)           
                count = count + 1

class worker_manager:
    # ...
    names = {'one': 'import_1', 'two': 'import_2'}
    def __init__(self):
        self.children = {}
    def generate(self, control_queue, threadName, runNum):
        name = self.names[threadName]
        target = i.getattr(name) #THis is throwing the error
        print ("Starting %s number %d") % (name, runNum)
        p = multiprocessing.Process(target=target, args=(control_queue, runNum))
        self.children[threadName] = p
        p.start()
    def terminate(self, threadName):
        self.children[threadName].join()

if __name__ == '__main__':
    # Establish communication queues
    control = multiprocessing.Queue()
    manager = worker_manager()    
    runNum = int(raw_input("Enter a number: ")) 
    threadNum = int(raw_input("Enter number of threads: "))
    threadName = raw_input("Enter number: ")
    thread_Count = 0

    print ("Starting threads") 

    for i in range(threadNum):
        if threadName == 'three':
            manager.generate(control, 'one', i)
            manager.generate(control, 'two', i)
        manager.generate(control, threadName, i)
        thread_Count = thread_Count + 1              
        if threadName == 'three':
            thread_Count = thread_Count + 1 

    time.sleep(runNum)#let threads do their thing

    print ("Terminating threads")     

    for i in range(thread_Count):
        control.put("t1kill")
        control.put("t2kill")
    if threadName == 'three':
        manager.terminate('one')
        manager.terminate('two')
    else:
        manager.terminate(threadName)
4

1 に答える 1

4 
def generate(self, control_queue, threadName, runNum):
    name = self.names[threadName]
    target = i.getattr(name) #THis is throwing the error

ihere は、ローカル スコープでは定義されていません。つまり、グローバルに定義されています。これは、参照している変数がここで定義されているものであることを意味します。

for i in range(threadNum):

それが意図的である場合、それは悪い習慣です。グローバル変数の使用は避けてください。また、それは整数です。あなたがやろうとしている：

  i.getattr(name)

整数について。それは何をすることになっていますか？動的に定義された属性を取得するために呼び出される関数がありgetattrますが、整数には動的属性がないため、何をしようとしているのかは不明です。

于 2013-08-01T02:52:51.597 に答える