|
|
@@ -48,7 +48,9 @@ def thompson_process(creative_id):
|
|
|
def get_creative_id_with_thompson(mid, creative_id_list):
|
|
|
"""利用Thompson采样获取此次要展示的广告创意ID"""
|
|
|
# 限制协程最大并发数：20
|
|
|
+ st_time6 = time.time()
|
|
|
gevent_pool = pool.Pool(100)
|
|
|
+ gevent_pool_time = int(time.time() - st_time6) * 1000
|
|
|
st_time5 = time.time()
|
|
|
tasks = [gevent_pool.spawn(thompson_process, creative_id) for creative_id in creative_id_list]
|
|
|
gevent.joinall(tasks)
|
|
|
@@ -66,6 +68,6 @@ def get_creative_id_with_thompson(mid, creative_id_list):
|
|
|
'random_flag': thompson_res_rank[0][3],
|
|
|
'thompson_res_rank': thompson_res_rank
|
|
|
}
|
|
|
- log_.info(f"get_random_time: {get_random_time}, sort_time: {sort_time}")
|
|
|
+ log_.info(f"gevent_pool_time: {gevent_pool_time}, get_random_time: {get_random_time}, sort_time: {sort_time}")
|
|
|
return rank_res
|
|
|
|
