public partial class PythonService
{
 private static readonly object _locker = new object();

 private static PythonService _instance;
 public static PythonService Current
 {
 get
 {
 if (_instance == null)
 {
 lock (_locker)
 {
  if (_instance == null)
  {
  _instance = new PythonService();
  }
 }
 }
 return _instance;
 }
 }

 private PythonService()
 {

 }
}

public partial class PythonService
{
 private string _workPath => Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "scripts");
 private string _pythonPath => Path.Combine(_workPath, "python27");

 private bool isRunning = false;
 private int taskPID = -1;

 public void Start()
 {
 taskPID = CreateProcess();
 isRunning = taskPID != -1;

 var msg = isRunning ? "服務(wù)啟動(dòng)成功..." : "服務(wù)啟動(dòng)失敗...";
 Trace.WriteLine(msg);
 }

 public void Stop()
 {
 KillProcessAndChildren(taskPID);

 isRunning = false;
 taskPID = -1;
 }

 private int CreateProcess()
 {
 KillProcessAndChildren(taskPID);

 int pid = -1;
 var psi = new ProcessStartInfo(Path.Combine(_pythonPath, "python.exe"))
 {
 UseShellExecute = false,
 WorkingDirectory = _workPath,
 ErrorDialog = false
 };

 psi.CreateNoWindow = true;

 var path = psi.EnvironmentVariables["PATH"];
 if (path != null)
 {
 var array = path.Split(new[] { ';' }).Where(p => !p.ToLower().Contains("python")).ToList();
 array.AddRange(new[] { _pythonPath, Path.Combine(_pythonPath, "Scripts"), _workPath });
 psi.EnvironmentVariables["PATH"] = string.Join(";", array);
 }
 var ps = new Process { StartInfo = psi };
 if (ps.Start())
 {
 pid = ps.Id;
 }
 return pid;
 }

 private static void KillProcessAndChildren(int pid)
 {
 // Cannot close 'system idle process'.
 if (pid <= 0)
 {
 return;
 }

 ManagementObjectSearcher searcher = new ManagementObjectSearcher("Select * From Win32_Process Where ParentProcessID=" + pid);
 ManagementObjectCollection moc = searcher.Get();
 foreach (ManagementObject mo in moc)
 {
 KillProcessAndChildren(Convert.ToInt32(mo["ProcessID"]));
 }
 try
 {
 Process proc = Process.GetProcessById(pid);
 proc.Kill();
 }
 catch (ArgumentException)
 {
 // Process already exited.
 }
 catch (Win32Exception)
 {
 // Access denied
 }
 }
}

public partial class PythonService
{
 private CancellationTokenSource cts;

 private void StartWatch(CancellationToken token)
 {
  Task.Factory.StartNew(() =>
  {
   while (!token.IsCancellationRequested)
   {
    var has = Process.GetProcesses().Any(p => p.Id == taskPID);
    Trace.WriteLine($"MQ狀態(tài)：{DateTime.Now}-{has}");
    if (!has)
    {
     taskPID = CreateProcess(_reqhost, _subhost, _debug);
     isRunning = taskPID > 0;

     var msg = isRunning ? "MQ重啟成功" : "MQ重啟失敗，等待下次重啟";
     Trace.WriteLine($"MQ狀態(tài)：{DateTime.Now}-{msg}");
    }

    Thread.Sleep(2000);
   }
  }, token);
 }
}

public void Start()
{
 taskPID = CreateProcess();
 isRunning = taskPID != -1;

 if (isRunning)
 {
  cts = new CancellationTokenSource();
  StartWatch(cts.Token);
 }

 var msg = isRunning ? "服務(wù)啟動(dòng)成功..." : "服務(wù)啟動(dòng)失敗...";
 Trace.WriteLine(msg);
}

public void Stop()
{
 cts?.Cancel(false);
 cts?.Dispose();

 KillProcessAndChildren(taskPID);
 taskPID = -1;

 isRunning = false;
}