如何在复制文件时调用cancel？(将复制文件ex函数与复制进度例程回调函数配合使用)

import shutil
import threading

# 标志位，用于判断是否需要取消复制操作
cancel_flag = False

# 复制进度例程回调函数
def progress_callback(current, total):
    # 更新进度条或显示当前的复制速度
    pass

# 复制文件的函数
def copy_file(source, destination):
    global cancel_flag

    # 复制文件的ex函数
    def copy_ex(src, dst):
        nonlocal cancel_flag

        # 复制文件的具体实现
        with open(src, 'rb') as fsrc, open(dst, 'wb') as fdst:
            while True:
                # 检查是否需要取消复制操作
                if cancel_flag:
                    # 取消复制操作
                    shutil.copyfileobj(fsrc, fdst)
                    break

                # 读取数据并写入目标文件
                data = fsrc.read(4096)
                if not data:
                    break
                fdst.write(data)

    # 创建一个线程来执行复制操作
    copy_thread = threading.Thread(target=copy_ex, args=(source, destination))
    copy_thread.start()

    # 等待复制线程结束
    copy_thread.join()

# 取消复制操作的函数
def cancel_copy():
    global cancel_flag
    cancel_flag = True

# 示例用法
source_file = 'source.txt'
destination_file = 'destination.txt'

# 复制文件
copy_file(source_file, destination_file)

# 取消复制操作
cancel_copy()