queue

    1熱度

    1回答

    我對tf.train.string_input_producer的工作原理有些疑問。因此,假設我將filename_list作爲輸入參數提供給string_input_producer。然後,根據文檔https://www.tensorflow.org/programmers_guide/reading_data,這將創建一個FIFOQueue,我可以在其中設置時代號,隨機播放文件名等。因此,就我

    0熱度

    1回答

    基本上,我想要讓我的程序只有一個實例可以一次運行。快速谷歌搜索this solution用於防止程序運行的兩個實例,我在下面修改,以便在運行之前等待前一個實例完成。 import fcntl, sys pid_file = 'program.pid' fp = open(pid_file, 'w') while True: try: fcntl.lockf(fp, fc

    -2熱度

    2回答

    這是while循環的正確邏輯: 1.如果堆棧不是空的執行... 2.檢查堆棧頂部的元素==隊列底部的元素。 這將繼續,直到堆棧/隊列首先完成(如果一個迴文,然後他們在同一時間完成)?我認爲對於if(s.pop()....)我必須用for循環來遍歷? 乾杯! for (int i = 0; i < word.length(); i++) { letter = word.charAt(i);

    0熱度

    1回答

    我想在Laravel中實現發送電子郵件的隊列。我的隊列工作正常,但擔心效率。這些是我的設置: 我已創建作業表並設置.env文件,以使用我的本地數據庫的隊列。 我已經建立了在服務器上的這個crontab中: * * * * * php /var/www/imagine.dev/artisan schedule:run >> /dev/null 2>&1 並在應用程序\ Conosle \ Ker

    1熱度

    2回答

    我已經完成了按隊列發送郵件的代碼,並且它工作正常,我想爲它編寫一個測試(只想測試應該正常發送的郵件而不排隊失敗,和正確的人),但如何? Mail::to($user->email)->queue(new Welcome($user));

    0熱度

    2回答

    我正在處理一個龐大的在線短信系統,用戶從其用戶面板發送消息,這些消息轉到名爲messages_queue的mysql表中。 然後,系統讀取隊列行併發送每個消息在Cronjob中。當然,以非常快的速度發送消息非常重要。 我在想,直接發送消息(根據用戶請求)並不使用隊列更好嗎? (發送消息需要連接到外部API) 我在考慮數據庫I/O時發現了這個問題。 這不是對數據庫的壓力嗎? 編輯/答: 我的問題是一

    0熱度

    1回答

    我在Java中使用一個LinkedBlockingQueue,我想在隊列中持有的元素之前釋放它的線程。換句話說,我想在元素退出隊列之前設置一個延遲。 private LinkedBlockingQueue<String> testQue = new LinkedBlockingQueue<String>() if (position.equals("leader")) { //proc

    1熱度

    3回答

    我開始構建批量上傳工具,並試圖解決如何完成其​​中一項要求。 這個想法是,用戶將上傳一個CSV文件,該工具將解析它,並將CSV的每一行發送到任務隊列作爲要運行的任務。然後,一旦完成了與該特定CSV文件有關的所有任務,就會向用戶發送摘要報告。 我使用的是Google App Engine,過去我使用標準任務隊列來處理任務。但是,使用標準任務隊列時,無法知道隊列何時完成,因此不會觸發事件觸發報告生成,

    1熱度

    1回答

    我有一個已經在使用cron發送郵件的系統。但我覺得這不是一個很好的實現,我想改進它。這就是我現在正在做的: 需要保存數據庫中的1行文本以及接收者的詳細信息,以及CTA的幾個,在cron裏面,我在主體中添加文本,添加標題&頁腳併發送它給用戶。 我打算它來改善這樣的: 使用刀片模板。 爲不同的動作創建不同的模板(例如註冊,忘記密碼等),現在沒有不同的模板。 一旦觸發操作,準備好準備發送給用戶的html

    0熱度

    1回答

    我與我所相信的嘗試是promise-queue var Queue = require("promise-queue") let queue = new Queue(); //add first item to queue queue.add(() => { console.log('start 1'); return new Promise((resolve, reject) =>