多线程执行Neo4j并行CREATE查询出现阻塞问题求助

问题根源 #

你遇到的阻塞本质是大事务+锁竞争导致的：

• 每个事务处理2500条关系，会长时间持有大量节点写锁（Gene和Concept节点的锁），16个并行事务同时争抢共享节点的锁时，极易形成锁等待链，最终所有事务陷入阻塞。
• 虽然appId已加索引，仅能加速节点匹配，但锁竞争的核心问题并未解决。之前的类似程序无问题，大概率是当时数据集没有热点节点（即没有被大量事务同时操作的节点），或事务粒度更小。

具体解决方案 #

• 缩小事务粒度：将每个事务处理的smRelRows数量从2500降至500甚至100条。小事务持有锁的时间更短，能大幅降低锁竞争概率，让事务更快完成并释放锁。
• 固定节点匹配顺序：确保所有事务的Cypher语句中，节点匹配顺序完全一致（比如始终先匹配Gene再匹配Concept）。避免不同线程出现反向匹配逻辑——若两个事务分别先锁A再锁B、先锁B再锁A，会直接触发死锁。
• 排查热点节点：执行CALL dbms.listLocks()查看当前锁等待情况，确认是否存在被所有事务争抢的热点节点（比如某个Gene或Concept被上万条关系指向）。如果有，可单独用单线程批量插入这类节点的关系，避免多线程争抢。
• 改用批量导入工具：如果是一次性导入大量数据，直接用Neo4j官方的neo4j-admin import工具。它绕过事务层直接写入磁盘，效率比应用层多线程插入高几个数量级，完全避免锁竞争问题。
• 临时调整锁超时配置：调大dbms.transaction.lock.timeout（默认60s），给事务足够时间获取锁，但这只是临时缓解，核心仍需解决锁竞争根源。

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