如何确保数据库轮询方法仅单线程运行，重复调用触发异常

要实现跨进程的单实例方法执行，核心是依赖系统级的同步原语——因为进程地址空间相互隔离，线程级锁（比如普通的lock、Monitor）无法跨进程生效。下面针对不同平台给出具体实现方案，确保同一时间只有一个线程（无论所属进程）能执行轮询方法，其他调用直接抛出异常。

Windows平台：使用命名互斥量（Named Mutex） #

Windows的命名互斥量是系统级对象，能跨进程识别。通过尝试获取互斥量的所有权，判断是否允许执行轮询逻辑。

实现步骤 #

1. 定义一个全局唯一的互斥量名称（建议包含应用程序唯一标识+方法名，避免与其他应用冲突）。
2. 在调用轮询方法前，非阻塞式尝试获取互斥量所有权：
   • 获取成功：执行轮询逻辑。
   • 获取失败：直接抛出异常。
3. 轮询结束后，务必释放互斥量，避免资源泄漏。

C#代码示例 #

using System;
using System.Threading;

public class DbPoller
{
    // 全局唯一互斥量名称，Global前缀确保跨终端服务会话生效
    private const string UniqueMutexName = "Global\\YourAppID_DbPolling_Mutex";
    private Mutex _pollMutex;

    public void ExecuteDbPolling()
    {
        bool isNewMutexCreated;
        try
        {
            // 创建或打开互斥量，不立即获取所有权
            _pollMutex = new Mutex(false, UniqueMutexName, out isNewMutexCreated);
            
            // 非阻塞尝试获取锁，超时时间设为0
            bool gotLock = _pollMutex.WaitOne(0);
            if (!gotLock)
            {
                throw new InvalidOperationException("数据库轮询方法已在其他进程/线程中运行");
            }

            // ----------------- 轮询逻辑开始 -----------------
            Console.WriteLine($"[{DateTime.Now}] 开始数据库轮询");
            // 这里编写你的数据库查询、处理逻辑
            // ...
            // ----------------- 轮询逻辑结束 -----------------
        }
        catch (AbandonedMutexException)
        {
            // 处理前序持有互斥量的进程异常崩溃的情况
            throw new InvalidOperationException("之前的轮询进程异常终止，当前无法启动新的轮询");
        }
        finally
        {
            // 释放并销毁互斥量
            _pollMutex?.ReleaseMutex();
            _pollMutex?.Dispose();
        }
    }
}

关键注意点 #

• 互斥量名称加上Global\前缀，可确保在多用户终端服务环境下跨会话生效；若不需要跨会话，可去掉该前缀。
• 必须处理AbandonedMutexException：当持有互斥量的进程异常退出时，系统会强制释放互斥量，但会抛出此异常，需根据业务需求决定是接管执行还是抛出异常。
• 一定要在finally块中释放互斥量，避免资源泄漏导致后续无法获取锁。

Linux/macOS平台：使用文件排他锁 #

类Unix系统中，可通过文件锁实现跨进程同步。利用fcntl系统调用获取文件的排他锁，同一时间只有一个进程能持有该锁。

实现步骤 #

1. 指定一个全局可访问的锁文件路径（比如/var/run/your_app_poll.lock）。
2. 打开锁文件，尝试非阻塞式获取排他锁：
   • 获取成功：执行轮询逻辑。
   • 获取失败：抛出异常。
3. 轮询结束后释放锁并关闭文件描述符。

C++代码示例 #

#include <fcntl.h>
#include <unistd.h>
#include <stdexcept>
#include <iostream>
#include <chrono>

void ExecuteDbPolling() {
    const char* lockFilePath = "/var/run/your_app_db_poll.lock";
    int lockFd = open(lockFilePath, O_CREAT | O_RDWR, 0666);
    if (lockFd == -1) {
        throw std::runtime_error("无法创建或打开锁文件");
    }

    struct flock lockInfo{};
    lockInfo.l_type = F_WRLCK;    // 排他写锁
    lockInfo.l_whence = SEEK_SET; // 从文件开头锁定
    lockInfo.l_start = 0;
    lockInfo.l_len = 0;           // 锁定整个文件

    // 非阻塞尝试获取锁
    int lockResult = fcntl(lockFd, F_SETLK, &lockInfo);
    if (lockResult == -1) {
        close(lockFd);
        throw std::runtime_error("数据库轮询方法已在其他进程/线程中运行");
    }

    try {
        // ----------------- 轮询逻辑开始 -----------------
        auto now = std::chrono::system_clock::now();
        std::time_t nowTime = std::chrono::system_clock::to_time_t(now);
        std::cout << "[" << std::ctime(&nowTime) << "] 开始数据库轮询" << std::endl;
        // 编写数据库查询、处理逻辑
        // ...
        // ----------------- 轮询逻辑结束 -----------------
    } catch (...) {
        // 异常时也要确保释放锁
        lockInfo.l_type = F_UNLCK;
        fcntl(lockFd, F_SETLK, &lockInfo);
        close(lockFd);
        throw;
    }

    // 正常结束后释放锁
    lockInfo.l_type = F_UNLCK;
    fcntl(lockFd, F_SETLK, &lockInfo);
    close(lockFd);
    // 可选：删除锁文件，避免残留
    unlink(lockFilePath);
}

关键注意点 #

• 锁文件路径要选全局可写的位置（比如/var/run），避免权限问题。
• 文件锁与文件描述符绑定，进程退出时系统会自动释放锁，即使异常崩溃也不会残留死锁。
• 使用非阻塞模式（F_SETLK）获取锁，失败立即抛异常，符合需求。

通用注意事项 #

1. 唯一性保障：同步对象的名称/锁文件路径必须全局唯一，建议嵌入应用程序的GUID、公司标识等，避免与其他应用冲突。
2. 线程安全：上述方案同时兼顾进程内的线程安全——同一进程内多个线程调用方法时，同步原语也会阻止并发执行。
3. 异常场景处理：要考虑前序进程异常崩溃导致锁未正常释放的情况，根据业务需求决定是接管执行还是直接抛异常。

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