|
|
@@ -7,6 +7,7 @@ import threading
|
|
|
from common import Material
|
|
|
# 控制读写速度的参数
|
|
|
from video_rewriting.video_prep import getVideo
|
|
|
+from video_rewriting.video_processor import VideoProcessor
|
|
|
|
|
|
MAX_BPS = 120 * 1024 * 1024 # 120MB/s
|
|
|
MAX_WORKERS = os.cpu_count() * 2 # 线程池最大工作线程数量
|
|
|
@@ -16,7 +17,7 @@ SLEEP_INTERVAL = READ_WRITE_CHUNK_SIZE / MAX_BPS # 控制每次读写的延迟
|
|
|
lock = threading.Lock()
|
|
|
|
|
|
def video_task_start(data):
|
|
|
- mark = getVideo.video_task(data)
|
|
|
+ mark = VideoProcessor.main(data)
|
|
|
print(f"返回用户名{mark}")
|
|
|
|
|
|
|
