关于redis开启事务机制的问题

老师在这个课堂内容中，关于撰写redis事务机制模拟秒杀活动我有问题：

代码块1：

try:
    if connection.exists('kill_flag') == 1:
        pipline.watch('kill_num','kill_user')
        total = int(pipline.get('kill_total').decode('utf-8'))
        num = int(pipline.get('kill_num').decode('utf-8'))
        if num < total:
            pipline.multi()
            pipline.incr('kill_num')
            user_id = s.pop()
            pipline.rpush('kill_user', user_id)
            pipline.execute()

代码块2：

for i in range(0, 1000):
    executor.submit(buy)

1）按照之前课程所描述的，当redis开启pipline.watch('kill_num', 'kill_user')时开启事务pipline.multi()后，当线程池异步执行buy任务的时候相当于有多个redis客户端同时修改pipline.watch()中的参数kill_num的数值，依照redis的事务机制当被检测的数据记录发生变化的时候，处在运行阶段的事务会被中断，那么在kill_num不断变化的阶段（kill_num<50的情况下）随着线程不断执行，redis中关于if num < total:以下的业务都会随着kill_num的数量不断加1而反复的终止业务

2）在这种情况下，redis在事务在由于kill_num不断变化的情况下不断被打断，这种情况下是如何能将pipline.rpsh('kill_user', user_id)以及kill_num等数据写入到redis中的？

这个逻辑我有些发蒙，绕不出来了，谢谢老师解答。