草庐IT

php - wordpress cron 作业是顺序执行还是并行执行？

coder 2023-12-30 原文

我正在尝试限制从我的网站发送的电子邮件数量，以应对托管服务电子邮件限制。 我正在使用 cron 作业和一个在数据库中堆积电子邮件的指示器来检查发送的电子邮件数量是否接近发送的最大电子邮件的限制。

我这样做的方法是直接执行预定进程，然后使其“休眠”一段时间(根据其在队列中的位置)，然后发送电子邮件并登录数据库。 为了进一步解释我使用计划任务和“ sleep ”的原因，请考虑以下场景:

  1. 一位用户尝试注册我的网站，并希望尽快向他/她发送一封电子邮件。因此，如果超过每分钟的电子邮件配额，我需要发送一条不同的消息:“我们的服务器正忙，请允许 'x' 分钟来执行所需的任务”。
  2. 发送电子邮件的请求都是通过 AJAX 完成的。在进程本身中使用“ sleep ”不是一种选择，因为用户将不得不等待 x 分钟，直到回显“忙消息”。
  3. 我尝试使用 ob_flush、flush...等。组合来回显消息，然后服务器在后台解决所有问题，但这从来没有奏效。 AJAX 调用一直在等待脚本结束以回显结果。

  4. 我需要单线程PHP语言中的多线程!作为一种解决方法，我使用了 cron 作业，其中每封堆积的电子邮件都计划在 time() 执行(即直接触发计划的作业)，它与发送电子邮件的相同功能 Hook 。使用标志，该函数知道请求是一堆电子邮件并使其“休眠”，直到电子邮件配额重置所需的时间。

  5. 问题:如果 5 个人几乎同时注册(而我们仍然有一堆电子邮件)，那么我们有 5 个 cron 作业应该同时执行，然后休眠一段时间(如果堆中的电子邮件数量已经大于电子邮件配额，则休眠时间可能会有所不同)，然后发送电子邮件。但是，当我查看数据库中的日志时，我发现计划的作业是顺序执行的，而不是并行执行的。有时会发生 cron 作业在其他端之前被触发，但它们不会同时触发。

我知道 wordpress cron 作业并不是真正的 cron 作业，一旦有人访问该网站就会被解雇(我确保在发送注册请求后刷新页面以触发所有计划任务)，但它们似乎对我来说是唯一的选择，因为我的托管服务器不允许访问服务器，也不允许安排 cron 作业。

下面是执行上述代码的部分代码:

//Test example to pile up emails, where quota is set to 2 emails every 30 seconds
$Emails_Threshold = 2;
$Threshold_Duration = 0.5*60;
//Get email indicator info
$Email_Info = $wpdb->get_row( 
"SELECT * 
FROM PileEmails 
WHERE priority = -1 
AND Status='New';"
,ARRAY_A);

if ($sleep ==0 && $Queue_Info_id==0){ //Not a scheduled event
   //Check if there are queued emails
   $Queue_exist = $wpdb->get_row (
    $wpdb->prepare("
                    SELECT Status 
                    FROM PileEmails
                    WHERE Status='Queued';"
                    ,$mail_priority)
                ,ARRAY_A);
  if (!empty($Queue_exist) || ($Email_Info['last_email_time']   > (time()-$Threshold_Duration))){
    if ($Email_Info['count_emails']>=$Emails_Threshold){
           //Code to Pile up
    }
  }else{ 
   //Reset email counter
  }
}else{ 
$wpdb->insert( "PileEmails",$Sleep_Info,$format);
sleep(10); //10 seconds here just as an example
}
//Code to send emails

这是我在超过配额后尝试发送 10 封电子邮件时登录到数据库的内容。

请注意，每个日志和下一个日志之间的时间戳有 10 秒的差异，尽管它们应该同时触发并且每个日志休眠 10 秒然后所有并行发送电子邮件。

所以我的问题是:为什么 wordpress cron 会按顺序而不是并行地触发计划的作业？以及如何克服这个问题？

非常感谢任何帮助。

最佳答案

如前所述，安装 cron 插件将有助于管理您的 cron。

为了回答您的问题，Wordpress 使用“cron lock”defined('DOING_CRON')并设置一个 transient $lock = get_transient('doing_cron')当spawn_cron方法被调用。

所以，如果你看一下 wp-includes/cron.php您会看到 Wordpress cron 默认情况下不会同时运行，并且不会每 60 秒运行一次以上。

// don't run if another process is currently running it or more than once every 60 sec.
    if ( $lock + WP_CRON_LOCK_TIMEOUT > $gmt_time )
        return;

关于php - wordpress cron 作业是顺序执行还是并行执行？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40544078/

wordpresscroncodesectionphp

有关php - wordpress cron 作业是顺序执行还是并行执行？的更多相关文章

  1. ruby-openid:执行发现时未设置@socket - 2

    我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时，我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb，在下面的代码片段中:moduleNetclass

  2. ruby - Chef 执行非顺序配方 - 2

    我遵循了教程http://gettingstartedwithchef.com/,第1章。我的运行list是"run_list":["recipe[apt]","recipe[phpap]"]我的phpapRecipe默认Recipeinclude_recipe"apache2"include_recipe"build-essential"include_recipe"openssl"include_recipe"mysql::client"include_recipe"mysql::server"include_recipe"php"include_recipe"php::modul

  3. ruby - 为什么 Ruby 的 each 迭代器先执行？ - 2

    我在用Ruby执行简单任务时遇到了一件奇怪的事情。我只想用每个方法迭代字母表，但迭代在执行中先进行:alfawit=("a".."z")puts"That'sanalphabet:\n\n#{alfawit.each{|litera|putslitera}}"这段代码的结果是:(缩写)abc⋮xyzThat'sanalphabet:a..z知道为什么它会这样工作或者我做错了什么吗？提前致谢。 最佳答案 因为您的each调用被插入到在固定字符串之前执行的字符串文字中。此外，each返回一个Enumerable，实际上您甚至打印它。试试

  4. ruby - 检查是否通过 require 执行或导入了 Ruby 程序 - 2

    如何检查Ruby文件是否是通过“require”或“load”导入的，而不是简单地从命令行执行的？例如:foo.rb的内容:puts"Hello"bar.rb的内容require'foo'输出:$./foo.rbHello$./bar.rbHello基本上，我想调用bar.rb以不执行puts调用。 最佳答案 将foo.rb改为:if__FILE__==$0puts"Hello"end检查__FILE__-当前ruby​​文件的名称-与$0-正在运行的脚本的名称。 关于ruby-检查是否

  5. postman——集合——执行集合——测试脚本——pm对象简单示例02 - 2

    //1.验证返回状态码是否是200pm.test("Statuscodeis200",function(){pm.response.to.have.status(200);});//2.验证返回body内是否含有某个值pm.test("Bodymatchesstring",function(){pm.expect(pm.response.text()).to.include("string_you_want_to_search");});//3.验证某个返回值是否是100pm.test("Yourtestname",function(){varjsonData=pm.response.json

  6. ruby-on-rails - rbenv:从 RVM 移动到 rbenv 后，在 Jenkins 执行 shell 中找不到命令 - 2

    我从Ubuntu服务器上的RVM转移到rbenv。当我使用RVM时，使用bundle没有问题。转移到rbenv后，我在Jenkins的执行shell中收到“找不到命令”错误。我内爆并删除了RVM，并从~/.bashrc'中删除了所有与RVM相关的行。使用后我仍然收到此错误:rvmimploderm~/.rvm-rfrm~/.rvmrcgeminstallbundlerecho'exportPATH="$HOME/.rbenv/bin:$PATH"'>>~/.bashrcecho'eval"$(rbenvinit-)"'>>~/.bashrc.~/.bashrcrbenvversions

  7. ruby - 带括号和 splat 运算符的并行赋值 - 2

    我明白了:x,(y,z)=1,*[2,3]x#=>1y#=>2z#=>nil我想知道为什么z的值为nil。 最佳答案 x,(y,z)=1,*[2,3]右侧的splat*是内联扩展的，所以它等同于:x,(y,z)=1,2,3左边带括号的列表被视为嵌套赋值，所以它等价于:x=1y,z=23被丢弃，而z被分配给nil。 关于ruby-带括号和splat运算符的并行赋值，我们在StackOverflow上找到一个类似的问题： https://stackoverflow

  8. ruby - 如何使用 Selenium Webdriver 根据 div 的内容执行操作？ - 2

    我有一个使用SeleniumWebdriver和Nokogiri的Ruby应用程序。我想选择一个类，然后对于那个类对应的每个div，我想根据div的内容执行一个Action。例如，我正在解析以下页面:https://www.google.com/webhp?sourceid=chrome-instant&ion=1&espv=2&ie=UTF-8#q=puppies这是一个搜索结果页面，我正在寻找描述中包含“Adoption”一词的第一个结果。因此机器人应该寻找带有className:"result"的div，对于每个检查它的.descriptiondiv是否包含单词“adoption

  9. ruby-on-rails - Rake 任务仅调用一次时执行两次 - 2

    我写了一个非常简单的rake任务来尝试找到这个问题的根源。namespace:foodotaskbar::environmentdoputs'RUNNING'endend当在控制台中执行rakefoo:bar时，输出为:RUNNINGRUNNING当我执行任何rake任务时会发生这种情况。有没有人遇到过这样的事情？编辑上面的rake任务就是写在那个.rake文件中的所有内容。这是当前正在使用的Rakefile。requireFile.expand_path('../config/application',__FILE__)OurApp::Application.load_tasks这里

  10. ruby-on-rails - 在 RSpec 中，如何以任意顺序期望具有不同参数的多条消息？ - 2

    RSpec似乎按顺序匹配方法接收的消息。我不确定如何使以下代码工作:allow(a).toreceive(:f)expect(a).toreceive(:f).with(2)a.f(1)a.f(2)a.f(3)我问的原因是a.f的一些调用是由我的代码的上层控制的，所以我不能对这些方法调用添加期望。 最佳答案 RSpecspy是测试这种情况的一种方式。要监视一个方法，用allowstub，除了方法名称之外没有任何约束，调用该方法，然后expect确切的方法调用。例如:allow(a).toreceive(:f)a.f(2)a.f(1)

随机推荐