Laravel是怎样防止你的定时任务重复执行的

基本介绍

有时候一个定时任务执行需要的时间可能会比我们想象的要长，这就会引起一个问题——当前任务还没有执行完毕的时候另一个相同的任务也会执行，从而导致任务重复。例如想象一下我们执行每分钟生成一次报告的任务，在经过一段时间后，数据量变得很大导致执行时间多于1分钟，这样就会导致在上一个任务还没结束的时候另一个相同的任务开始执行。

解决方法

大部分情况下是没有什么问题的，但是有时我们需要避免这种情况来保证获得正确的数据。在laravel中我们可以通过withoutoverlapping方法来进行处理

$schedule->command('mail:send')->withoutoverlapping();

 

laravel会检查console\scheduling\event::withoutoverlapping属性，如果该值为true那么将会针对这个任务创建一个互斥锁(mutex)，并且只有在可以创建互斥锁的情况下才会执行此任务。

什么是互斥锁？

这是我在网上找到的最有趣的解释：

当我们在开会进行激烈的讨论时，我会从我桌子里拿出来一个尖叫鸡。只有手里拿着尖叫鸡的人才能说话，如果你没有拿着尖叫鸡你是不能说话的。你只能向会议主持人请示，只有在你拿到尖叫鸡的时候你才能说话否则只能等待。当你讲话完毕的时候，将尖叫鸡还给会议主持人，主持人会将尖叫鸡给到下一个人来让其说话。这样会确保人们不会互相交谈，同时他们也会有自己的时间来进行讲话。

将尖叫鸡换成互斥锁，人换成线程。你基本上就有了一个互斥锁的基本概念。

 

链接：https://pan.baidu.com/s/1v5gm7n0l7tgyejcmqrmh2g 提取码：x2p5

免费分享，但是x度限制严重，如若链接失效点击链接或搜索加群 群号518475424。

原理分析

laravel在第一次执行任务的时候会创建一个互斥锁，然后在每次执行任务时会检查互斥锁是否存在，只有互斥锁不存在的时候任务才会执行。下面是withoutoverlapping方法：

public function withoutoverlapping()

{

    $this->withoutoverlapping = true;

 

    return $this->then(function () {

        $this->mutex->forget($this);

    })->skip(function () {

        return $this->mutex->exists($this);

    });

}

 

laravel创建了一个过滤回调方法来告诉计划管理器忽略互斥锁仍然存在的任务，同时也创建了一个在完成任务实例后清除互斥锁的回调。同时，在执行任务之前，lravel会在console\scheduling\event::run()方法中依次执行下面一系列的检查：

if ($this->withoutoverlapping && ! $this->mutex->create($this)) {

    return;

}

 

那么互斥锁的属性是从哪里来的呢？

当console\scheduling\schedule被实例化的时候，laravel会检查console\scheduling\mutex是否绑定到了容器，如果是那么就会实例化它，否则会使用console\scheduling\cachemutex

$this->mutex = $container->bound(mutex::class)

                        ? $container->make(mutex::class)

                        : $container->make(cachemutex::class);

 

现在当任务管理器在注册事件的时候会将互斥锁的实例一并传进去：

$this->events[] = new event($this->mutex, $command);

 

laravel默认使用了缓存实现的互斥锁，但是你可以自己实现并替换它。

缓存版的互斥锁

cachemutex类只有3个简单的方法，它使用了事件互斥锁的名字作为缓存的键值：

public function create(event $event)

{

    return $this->cache->add($event->mutexname(), true, 1440);

}

 

public function exists(event $event)

{

    return $this->cache->has($event->mutexname());

}

 

public function forget(event $event)

{

    $this->cache->forget($event->mutexname());

}

 

就像我们之前看过的，管理器注册了一个执行后回调来保证任务执行完毕的时候移除互斥锁，对于一个系统里的命令来说也许已经可以确保移除了。但是对于一个回调方法的任务来说脚本可能在执行回调的时候结束，因此为了避免这种情况在console\scheduling\callbackevent::run()方法中加入了下面的代码确保互斥锁在任务意外关闭的时候能够正常移除：

register_shutdown_function(function () {

    $this->removemutex();

});