0

我有这个代码:

class Server(object):
    servers = []

    def __init__(self, name, host, port, process):
        self.name = name.lower()
        self.host, self.port = host, port
        self.process = process
        self.pid = self.process.pid

    @staticmethod
    def register(server):
        Server.servers.append(server)

    @staticmethod
    def unregister(server):
         Server.servers.remove(server)

def start_waitress(host='0.0.0.0', port=8080):
     args = ['--port={}'.format(port),
         '--host={}'.format(host), 'yarr.wsgi:application']

    subprocess.call(['waitress-serve'] + args)

 ...

 host, port = '0.0.0.0', 8080
 process = multiprocessing.Process(target=start_waitress)
 process.start()
 Server.register(Server('waitress', host, port, process))

 ...

for server in Server.servers:
   if server.name == 'waitress':
       server.process.terminate() # Here's the problem
       Server.unregister(server)
       break

问题是我无法在启动后终止进程。

我可以终止进程的唯一方法是运行kill <pid>.

如何终止该过程?

4

1 回答 1

0

正如 JF Sebastian 所说,waitress-serve将自己守护。

我无法解决这个问题,multiprocessing但我找到了一个解决方案subprocess

而不是创建multiprocessing.Process我调用subprocess.Popen(cmd).

class Server(object):
    servers = []

    def __init__(self, name, host, port, pipe):
        self.name = name.lower()
        self.host, self.port = host, port
        self.pipe = pipe

    @staticmethod
    def register(server):
        Server.servers.append(server)

    @staticmethod
    def unregister(server):
        Server.servers.remove(server)

def start_waitress(host='0.0.0.0', port=8080):
    args = ['--port={}'.format(port),
         '--host={}'.format(host), 'yarr.wsgi:application']

    return subprocess.Popen(['waitress-serve'] + args)

...

host, port = '0.0.0.0', 8080
Server.register(Server('waitress', host, port, start_waitress()))

...

for server in Server.servers:
  if server.name == 'waitress':
      server.pipe.terminate()
      server.pipe.wait()
      Server.unregister(server)
      break
于 2014-10-14T05:51:17.830 回答