python - Python スレッドがグローバル変数に反応しないのはなぜですか

Question

このコードは、さまざまな種類のスレッドの複数のコピーを開始および停止するためのものです。パイプを使用してスレッドを制御しようとしましたが、パイプに関係するランダムなメモリ エラーが発生し続けると言って、これを前置きします。これは、複数のスレッド タイプの複数のコピーを生成するためのファクトリのプロトタイプであるため、キュー メソッドも実用的ではないように思われました。したがって、私の最新の計画は、すべてのスレッドとスレッドの強制終了条件に対して異なるエントリを持つグローバル ディクショナリを使用することです。すなわちsub[Alive] subKill["kill"]

しかし、何らかの理由でcontrol_listener、プロセスによって生成されたスレッドは強制終了条件をトリガーせず、グローバル変数を読み取りません。

from multiprocessing import Process, Pipe
from threading import Thread
import time


alive = {'subAlive': True, 'subKill': "Alive", 'testAlive': True, 'testKill': "Alive"};


def control_listener(aliveFlag, threadAlive): #listens for kill from main
    global alive
    while True:
          data = alive[aliveFlag];
          print "Thread", alive[threadAlive];
          print "Thread status", alive[aliveFlag];
          if data == "kill":
             print "Killing"
             alive[threadAlive] = False; #value for kill
             print "testListner alive %s" % threadAlive, alive[threadAlive];
             print "deactivating %s" % threadAlive, alive['aliveFlag'];
             break

def subprocess(aliveFlag, threadNum, threadAlive):
    t = Thread(target=control_listener, args=(aliveFlag, threadAlive))
    count = 0
    threadVal = threadNum 
    t.start()
    run = alive['subAlive'];
    while run == True:
          print "Thread alive %s" % alive['aliveFlag'];
          print "Thread %d Run number = %d" % (threadVal, count), alive['subAlive'];
          count = count + 1
          run = alive['subAlive']; 


def testprocess(aliveFlag, threadNum, threadAlive):
    t = Thread(target=control_listener, args=(aliveFlag, threadAlive))
    count = 0
    threadVal = threadNum 
    t.start()
    run = alive['testAlive'];
    while run == True:
          print "This is a different thread %d Run = %d" % (threadVal, count)
          count = count + 1
          run = alive['testAlive'];


runNum = int(raw_input("Enter a number: ")) 
threadNum = int(raw_input("Enter number of threads: "))


print "Starting threads"

for i in range(threadNum):
    p = Process(target=subprocess, args=('subKill', i, 'subAlive'))
    p.start()

print "Subprocess started"

for i in range(threadNum): 
    p2 = Process(target=testprocess, args=('subKill', i, 'testAlive'))
    p2.start()

print "Testproccess started"

print "Starting run"

time.sleep(runNum) 

print "Terminating Subprocess run"
for i in range(threadNum):
    alive['subKill'] = "kill"; 
    print "Subkill = %s" % alive['subKill'];
    print "Testprocess termination alive", alive['subAlive'];

print "Terminating Testprocess run"
for i in range(threadNum):
    alive['subKill'] = "kill"; 
    print "Testprocess termination alive", alive['subAlive'];

p.join()
p2.join()