Java程序中断执行后恢复方法咨询：需保存已计算状态

嘿，这个需求我太熟了——暴力求解旅行商问题（TSP）这类组合优化任务，最怕中途断电或关机，之前几天的计算全白费。下面给你梳理几个实战验证过的中断恢复方案，核心都是检查点（Checkpoint）机制，确保所有已计算的信息都能持久化保存，下次启动直接续上：

这是最容易实现的方案，适合中小规模的计算任务。

要保存的核心状态 #

每次完成一批计算后，把以下信息写入文件：

• 已处理完的计算分片标记（比如哪些路径子集已经遍历过）
• 当前找到的全局最优路径及其长度
• 遍历进度标记（比如当前处理到哪一条排列，或者分片的起始索引）

实现示例（Python） #

用pickle或者json序列化状态字典，注意写入时的原子性（避免中途断电损坏文件）：

import pickle
import os
from pathlib import Path

CHECKPOINT_PATH = Path("tsp_checkpoint.pkl")

def save_checkpoint(processed_blocks: list, current_best: tuple, progress: int):
    # 先写临时文件，再替换原文件，保证原子性
    tmp_path = CHECKPOINT_PATH.with_suffix(".tmp")
    with open(tmp_path, "wb") as f:
        pickle.dump({
            "processed_blocks": processed_blocks,
            "current_best": current_best,  # 格式：(路径列表, 总长度)
            "progress": progress
        }, f)
    tmp_path.replace(CHECKPOINT_PATH)

def load_checkpoint():
    if CHECKPOINT_PATH.exists():
        with open(CHECKPOINT_PATH, "rb") as f:
            return pickle.load(f)
    # 第一次运行的初始状态
    return {"processed_blocks": [], "current_best": (None, float("inf")), "progress": 0}

关键注意事项 #

• 不要每算一条路径就存一次——太影响性能！可以设置批次，比如每处理1000条路径或完成一个分片后再保存。
• 优先用二进制序列化（比如pickle），比JSON更高效，还能直接保存复杂数据结构。

如果你的城市数量较多（比如15+个，排列数已经是千亿级别），文件系统的读写效率和查询能力会跟不上，这时用SQLite这类嵌入式数据库更合适。

核心思路 #

把计算任务拆分成多个独立分片，每个分片的处理状态、最优值都存在数据库表里：

1. 创建tsp_blocks表：记录每个分片的ID、是否处理完成、该分片的最优路径和长度
2. 创建tsp_global表：单独存储当前全局最优解

优势 #

• 支持事务写入，断电后不会出现数据损坏
• 可以快速查询哪些分片未处理，不用遍历整个文件
• 后续扩展多进程/多线程计算时，能方便地做分片调度

暴力TSP本质是遍历所有城市的排列，我们可以把所有排列按规则拆分成多个独立分片，比如：

• 固定前2个城市的组合，把所有排列分成n*(n-1)个分片（n是城市数量）
• 每个分片只处理剩余n-2个城市的全排列

程序启动时，先检查哪些分片已经处理完成，直接跳过，只处理未完成的分片。这种方式的好处是：就算某个检查点损坏，最多只丢失一个分片的计算量，而不是全部。

除了主动保存检查点，还要处理系统发送的中断信号（比如Ctrl+C、关机信号），自动触发保存，避免用户忘记手动操作。

Python示例（Linux/Windows通用） #

import signal
import sys

def handle_interrupt(signum, frame):
    print("\n收到中断信号，正在保存检查点...")
    save_checkpoint(processed_blocks, current_best, progress)
    print("检查点保存完成，程序退出")
    sys.exit(0)

# 注册信号处理
signal.signal(signal.SIGINT, handle_interrupt)  # Ctrl+C
signal.signal(signal.SIGTERM, handle_interrupt) # 系统终止信号

程序启动时，先调用load_checkpoint()加载之前的状态：

1. 读取已处理的分片和当前全局最优解
2. 从上次中断的进度位置开始继续遍历，或者直接跳过已处理的分片
3. 每次计算新路径时，和当前全局最优对比，更新最优解
4. 定期保存检查点

• 提前剪枝：如果当前路径的长度已经超过全局最优，直接跳过后续的路径扩展，能大幅减少计算量
• 多进程分片：把分片分配给多个进程并行计算，每个进程写自己的检查点，最后合并全局最优解

内容的提问来源于stack exchange，提问作者ruigomes