0

我有一个类MyClass在初始化时创建 7 个线程。一个线程是 TCPServer，另外六个是MyClassTCPServer 用来处理请求的对象。

我的目的是创建可以在后台运行MyClass并维护 6 个线程的方法。这 6 个线程对应于 2 个分布式对象obj1，并obj2通过名为 PySyncObj 的 Raft 实现进行复制。每个对象有三个线程。

每个对象集群obj_1_cluster都有obj_2_cluster一个领导者，服务器必须跟踪它，因为对对象的所有更改都必须只发送给领导者。

class MyClass(object):

def __init__(self):

    self.server = TCPServer()

    self.obj_1_cluster = self.init_cluster(Class_1['bindings'], Class_1)
    self.server.obj1 = self.get_leader(obj_1_cluster)

    self.obj_2_cluster = self.init_cluster(obj_2['bindings'], Class_2)
    self.server.obj2 = self.get_leader(obj_2_cluster)


    # Create Daemon process for keeping leader current.
    self.obj1_leader_daemon = Thread(target = self.__obj1_leader_daemon())
    self.obj1_leader_daemon.setDaemon(True)
    self.obj1_leader_daemon.start()

    self.obj2_leader_deamon = Thread(target = self.__obj2_leader_daemon())
    self.obj2_leader_deamon.setDaemon(True)
    self.obj2_leader_deamon.start()

def __obj1_leader_daemon(self):
    while True:
        print("Running obj1 daemon")
        if self.server.obj1._isLeader():
            pass
        else:
            self.server.obj1 = self.get_leader(self.obj1)

def __obj2_leader_daemon(self):
    while True:
        print("running obj2 daemon")
        if self.server.obj2._isLeader():
            pass
        else:
            self.server.obj2 = self.get_leader(self.obj2)

当我运行这段代码时，我看到的唯一输出是......

Running obj1 daemon
Running obj1 daemon
Running obj1 daemon
...

直到我用 ctrl-C 终止进程。

有没有办法改变这一点，以便这两个进程可以使用自己的线程运行——在需要更改对象时忙于检查对象的状态？我已经阅读了很多关于线程的内容，但我不明白为什么这目前没有按照我认为的方式工作。

环境：我在 MacOS 10.13.3 上运行 python 2.7.14。

4

1 回答 1

1

__init__卡在

self.obj1_leader_daemon = Thread(target = self.__obj1_leader_daemon())

线程目标应该是要运行的函数的名称，但您已经调用了该函数。self.__obj1_leader_daemon()是一个无限循环，因此它永远不会返回，没有分配任何内容，也target没有创建线程。您的主线程挂起运行守护程序代码。

只需去掉牛仔腿

self.obj1_leader_daemon = Thread(target = self.__obj1_leader_daemon)

...并对另一个线程执行相同的操作。

于 2018-03-04T23:51:50.647 回答