Nodejs setInterval 会引发并发问题么

Nodejs setInterval 会引发并发问题么

如题，顶一个一个统计量 function Stat() { this.visit = 0; this.hitration = 0; } 如果我统计程序的访问量以及搜索的命中率，每两个小时回写一次数据库，然后删除这个对象，利用Timers的setinterval函数非常合适，但是我在回写数据库并删除统计量的 时候，会出现有人访问，这个时候程序还要操作统计量，会引发并发问题么

3 回复

Node.js setInterval 是否会引起并发问题？

在使用 Node.js 的 setInterval 定时器时，确实有可能会引发并发问题。特别是在定时器回调中对共享资源（如全局变量）进行操作时，如果没有适当的同步机制，可能会导致数据不一致或竞态条件。

示例代码

假设我们有一个简单的统计量对象，用于记录网站的访问量和搜索命中率：

function Stat() {
    this.visit = 0;
    this.hitration = 0;
}

const stat = new Stat();

// 每两小时回写数据库，并删除统计量
setInterval(() => {
    console.log('正在回写数据库...');
    // 假设这里有一个函数 `writeToDatabase` 用于将统计数据写入数据库
    writeToDatabase(stat, () => {
        console.log('数据库回写完成');
        stat.visit = 0; // 清零
        stat.hitration = 0;
    });
}, 7200000); // 7200000 ms = 2 hours

// 模拟访问网站
function visitWebsite() {
    stat.visit++;
    console.log(`当前访问量: ${stat.visit}`);
}

// 模拟用户访问
visitWebsite();
visitWebsite();

并发问题分析

在这个例子中，setInterval 定时器每两小时执行一次回调函数，该函数会回写数据库并将统计量清零。同时，当用户访问网站时，visitWebsite 函数会增加访问量计数。

潜在问题：

  1. 竞态条件：如果在定时器回调执行过程中有新的访问发生，那么可能会出现数据竞争。例如，在读取 stat.visit 计数后但在更新数据库之前，新的访问可能已经增加了 visit 计数，导致最终写入数据库的数据不准确。

  2. 数据不一致：如果在定时器回调中清零了统计量，而此时恰好有新的访问发生，新的访问数据可能会丢失。

解决方案

为了防止并发问题，可以使用锁机制或者确保在操作共享资源时不会被其他操作打断。例如，使用互斥锁（Mutex）来保证在特定时间段内只有一个操作可以访问共享资源。

const mutex = require('async-mutex').Mutex;

const statMutex = new mutex();

function visitWebsite() {
    statMutex.runExclusive(() => {
        stat.visit++;
        console.log(`当前访问量: ${stat.visit}`);
    });
}

// 修改定时器回调函数以使用互斥锁
setInterval(async () => {
    await statMutex.runExclusive(async () => {
        console.log('正在回写数据库...');
        await writeToDatabase(stat);
        console.log('数据库回写完成');
        stat.visit = 0;
        stat.hitration = 0;
    });
}, 7200000);

通过使用互斥锁，我们可以确保在定时器回调执行期间，不会有其他操作修改共享资源，从而避免并发问题。


node是单线程的。

使用 setInterval 在 Node.js 中可能会引发并发问题，特别是当你在回调函数中对共享数据进行读取和修改时。这是因为 setInterval 是异步的，并且可能在一个定时器回调还在执行时触发下一个回调。

示例代码

假设我们有一个 Stat 类，用于记录网站的访问次数和点击率：

class Stat {
	constructor() {
		this.visit = 0;
		this.hitration = 0;
	}

	incrementVisit() {
		this.visit++;
	}

	updateHitration(newHitration) {
		this.hitration = newHitration;
	}
}

const stat = new Stat();
let intervalId;

function writeAndResetStats(stat) {
	console.log("Writing and resetting stats...");
	stat.updateHitration(0);
	stat.incrementVisit(); // 这里可能会出错
}

intervalId = setInterval(() => {
	writeAndResetStats(stat);
}, 2 * 60 * 60 * 1000); // 每两小时执行一次

// 模拟访问
setInterval(() => {
	stat.incrementVisit();
}, 1000); // 每秒访问一次

在这个例子中，writeAndResetStats 函数会在每两小时执行一次，它会尝试重置统计信息。同时，模拟的访问函数每秒调用一次 incrementVisit 方法。

并发问题

当 writeAndResetStats 函数正在执行时，如果另一个访问事件触发了 incrementVisit，可能会导致并发问题。例如，在 writeAndResetStats 重置 hitration 后但还没有增加 visit 的情况下，新的访问可能会覆盖掉 writeAndResetStats 中的操作，导致统计数据不准确。

解决方案

为了避免这种并发问题，你可以考虑以下几种方法：

  1. 互斥锁：使用一个锁来确保同一时间只有一个线程可以修改统计信息。
  2. 避免长时间运行的任务：尽量减少定时器回调的执行时间，使它们快速完成。
  3. 使用队列：将所有的修改操作放入一个队列，由单独的线程或进程处理这些队列中的任务。

示例：使用锁

let isUpdating = false;

const stat = new Stat();

function writeAndResetStats(stat) {
	if (isUpdating) return;
	isUpdating = true;

	console.log("Writing and resetting stats...");
	stat.updateHitration(0);
	stat.incrementVisit();
	isUpdating = false;
}

// 其他部分代码保持不变

在这个版本中，我们引入了一个标志变量 isUpdating，以确保在写入和重置统计信息时不会同时发生其他修改操作。

回到顶部