worker

    1熱度

    1回答

    我一直在我的代碼中存在一段時間的錯誤,但無法弄清楚如何解決它。我試圖實現的很容易:每個工人節點(即排名!= 0的節點)在涉及一些計算的正方形結構中獲得一行(由一維arry表示)。計算完成後,該行將被髮送回主設備。 出於測試目的,不涉及計算。所有這一切發生的事情是: 主機發送行號工人,工人使用的行數,結果值回 來計算相應的值 工人發陣列現在,我的問題是這樣的: 如在一排(大小= 1006)和工人>

    1熱度

    1回答

    我有興趣使用Gearman服務器在我的PHP應用程序中分發長時間運行的作業。不幸的是,我沒有直接訪問我的應用程序服務器,我無法安裝任何PECL擴展。 是否有一個純粹的PHP客戶端庫,我可以使用?

    2熱度

    1回答

    我已經使用Codeigniter構建了一個應用程序,現在我想使用Gearman作業排隊服務器來背景一些長時間運行的任務。我正在使用Net_Gearman PEAR庫(不太需要安裝模塊,但不幸的是,我無法在服務器設置上安裝其他模塊)。是否有任何優秀的教程或指導,以實現將該庫與codeigniter集成的最佳實踐方式?也許甚至是爲codeigniter定製的庫?謝謝!

    0熱度

    1回答

    我有一個CodeIgniter項目,我想通過CLI調用我的一個控制器方法,但正常屬性&連接到CI超級對象的方法似乎丟失了? 例如,運行運行在正常的HTTP請求時完全沒有下面的腳本產生一個錯誤: class Worker extends MY_Controller { public function __construct() { if(php_sapi_name() !==

    0熱度

    1回答

    我想從我的工作者函數中訪問當前作業的job_id,這樣我就可以將結果保存到等於當前工作者函數的鍵下的memcached。有什麼辦法可以做到這一點? <?php class Net_Gearman_Job_Example1 extends Net_Gearman_Job_Common{ public function run($arg){ echo 'job_

    3熱度

    1回答

    我們有一個用PHP編寫的輕量級跟蹤腳本,運行在Apache/2.2.14(Ubuntu)上。該腳本將收到大量的併發連接,但每個連接都會很快。目前,我們正在使用的prefork,配置如下: StartServers 5 MinSpareServers 5 MaxSpareServers 10 ServerLimit 600 MaxClients 600 MaxRequest

    1熱度

    1回答

    我正在使用工具分配工具在多個工作服務器上分發長時間運行的任務。對於我的一個工作任務,我嘗試調用另一個後臺作業。後臺作業由另一名工作人員成功執行......但該工作進程並未響應之後添加到齒輪工的任何新作業。 任何人都知道可能會發生什麼?這是齒輪工的特點嗎? 編輯: 另外,如果我重新啓動我的工人,他們重複被其他工人排隊的任務。 Gearman似乎沒有意識到這項工作已經完成。 編輯2: 嘗試: var_

    8熱度

    1回答

    我無法調用從包括模塊resque工人內部方法的Rails Resque未定義的方法錯誤。在下面的示例中,當我嘗試調用Worker中的say方法(位於TestLib模塊中)時,我不斷收到未定義的方法錯誤。我已經減少了代碼到裸露的基礎來說明這個問題: 控制器 (/app/controllers/test_controller.rb) class TestController < Application

    0熱度

    1回答

    我正在尋找一些建議/意見的哪個Python框架用於實施多個'工人'個人電腦從中央隊列管理器協調。 爲了完整起見,'工人'電腦將運行音頻轉換例程(我不需要建議,並且可以使用獨立代碼)。 音頻轉換需要很長時間,我需要從中心位置協調任意數量的'工作人員',將他們轉換任務(例如獲取源文件的位置或向何處提問對於作業配置)與他們報告一些額外的信息,如轉換音頻的運行時間等。 目前,我有一個腳本,使web服務調用

    3熱度

    3回答

    我不熟悉併發編程,並且一直在處理具有要處理的項目隊列的代碼,這會傳遞給某些工作線程,即由用戶指定的編號。目前,我只是試圖用兩個工作線程加上主線程來完成它。 private static class workerThread extends Thread { workerThread(){ super(); } public void run(