import random
from concurrent.futures.thread import ThreadPoolExecutor
import redis

pool = redis.ConnectionPool(
    host="localhost",
    port=6379,
    db=2,
    max_connections=20
)
con = redis.Redis(
    connection_pool=pool
)

people = set()
for i in range(0,1000):
    temp = random.randint(1000, 999999)
    people.add(temp)
print(people)
print(len(people))





try:
    con.delete('k_num','k_total','k_buy','k_flag')
    k_num = con.set('k_num',0)
    k_total = con.set('k_total',50)
    k_flag = con.set('k_flag',1)
    con.expire('k_flag',600)
except Exception as e:
    print(e)
finally:
    del con


def ms():
    connection = redis.Redis(
        connection_pool=pool
    )
    pipline = connection.pipeline()
    try:
        if connection.exists('k_flag'):
            pipline.watch('k_num', 'k_buy')
            num = int(pipline.get('k_num').decode('utf-8'))
            total = int(pipline.get('k_total').decode("utf-8"))

            if num < total:
                pipline.multi()
                p_buy = people.pop()
                pipline.rpush('k_buy',p_buy)
                pipline.incrby('k_num')
                pipline.execute()
    except:
        pass
    finally:
        pipline.reset()
        del connection

executor = ThreadPoolExecutor(max_workers=50)
for i in range(len(people)):
    executor.submit(ms)

我测试了好几次，为什么偏偏在线程数量为50的时候会出现少于规定数量的数据，线程数量为20，100的时候就没问题，这里面出了什么问题吗