import time
import multiprocessing

#一个可调用对象可用作子进程运行
def clock(interval): 
  while True: 
    print("P1: The time is {}".format(time.ctime()))
    time.sleep(interval)

#通过继承 multiprocessing.Process 也可以定义一个子进程
class ClockProcess(multiprocessing.Process): 
  def __init__(self, interval): 
    multiprocessing.Process.__init__(self) 
    self.interval = interval 
  #重新定义 run 函数（进程启动时运行的函数）
  def run(self): 
    while True: 
      print("P2: The time is {}".format(time.ctime()))
      time.sleep(self.interval) 

# 打开程序第一个参数是一个列表（程序名称，参数)
# 第二个参数是缓冲区大小
# stdin,stdout是设置是否打开这些管道，如果他的值是subprocess.PIPE的话，
# 就会打开,同stdin一样的还有stderr
# child = subprocess.Popen(["python","in.py"], bufsize=1024, stdin=subprocess.PIPE, 
# stdout=subprocess.PIPE)

# i = 0
# while True:
#   if i > 10:
#     break
#   else:
#     i += 1
#     child.stdin.write(str(i).encode())
#     child.stdin.write(b"\n")
#     child.stdin.write(str(i+1).encode())
#     child.stdin.write(b"\n")
#     child.stdin.flush()
#     fb = child.stdout.readline()
#     print(fb.decode().strip())
#     sleep(1)

# child.kill()


if __name__ == "__main__":
  #创建一个子进程
  p1 = multiprocessing.Process(target=clock, args=(5,))
  p2 = ClockProcess(5)
  #后台进程
  p1.daemon = True
  p2.daemon = True
  #启动子进程
  p1.start()
  p2.start()
  #因为两个子进程是后台进程，所以主进程不能退出，否则这些子进程也将退出
  input()