queue

    0熱度

    1回答

    我有一個線程從輸入隊列中讀取數據,對它執行某些操作,然後將結果放到輸出隊列中以供以後使用。但是,它看起來像線程只能寫入輸出隊列一次。我究竟做錯了什麼?以下是我的代碼的高度簡化的自包含版本。 import queue import threading def do_work(input_queue,output_queue): input_number = input_queue.

    1熱度

    1回答

    #Version1 main_df = pd.read_csv('Million_rows.csv') def myfunction(args*,start,end): for i in range(start,end): if condition1: for item in mainTreeSearch: ... lock.acq

    1熱度

    1回答

    在使用Redis處理排隊系統時,我可能會用錯誤的思維方式,這就是爲什麼我需要你們爲此提供幫助。 所以,我有這個相當簡單的隊列,負責將電子郵件堆疊到一個集合上,然後檢索堆棧的可用電子郵件並分發它。 該系統是在NodeJS中構建的,因此我正在使用node-redis lib。 隊列(堆棧)應該是不斷可用的,一個點在其上添加(推送)新的電子郵件,另一個則彈出第一個被推入的項目。 對於這種方法,我可能會想

    -1熱度

    1回答

    您的研究機構剛剛收到一臺新的超級計算機。它能夠同時處理幾項不同的任務,但前提是它知道每項任務需要多長時間才能得出結果。 這臺超級計算機測量時間以時間爲單位,並在以下方式操作: 需要處理的所有任務都放置在隊列中。 隊列頂部的任務恰好給定了1個CPU時間單位。如果未完成,則將其放置在隊列的後面。 隊列中的任務重新調度由特殊處理單元管理,因此不需要額外的CPU時間。 您已將您的任務提交到處理隊列,並且您

    -1熱度

    1回答

    我對隊列的實現以一種奇怪的方式工作:當我排隊新元素時 - 一切正常,但是當我開始出隊時 - 它刪除最後添加的元素,儘管此時我的頭是1尾巴更大。 C++中索引的用法是什麼?爲什麼它的行爲如此? 這裏是我的全碼: https://hastebin.com/odibusacuk.cpp class Queue{ public: int head=1; int tail=1; int q[MAX]

    0熱度

    1回答

    我有一個項目,我正在將作業添加到隊列中,並且我有多個線程正在進行作業,並計算出自己的獨立結果。 我的程序處理SIGINT信號,我試圖加入線程來合併結果,打印到屏幕,然後退出。我的問題是,當我發送信號時線程似乎停止工作,或者他們在mutex_lock上被阻塞。這裏是我的程序的重要部分,以便簡潔。 的main.c //the thread pool has a queue of jobs inside

    -4熱度

    1回答

    我是C++的初學者。我試圖按隊列順序(FIFO)寫一個動態分配的鏈表。該程序可以編譯並運行。但我無法打印任何東西。所以我不知道鏈接或打印輸出邏輯中是否存在問題。請幫忙。 #include <iostream> using std::cout; using std::cin; using std::endl; using std::ios; #include <iomanip> usin

    0熱度

    1回答

    這是一個結構,我給了一個返回指向新的空隊列的指針的隊列。我知道隊列 - >後端指向隊列後面的節點,隊列 - >後 - >下一個指向隊列前端的節點。我如何稱呼隊列的前端?每當我使用queue-> rear-> next時,我都會遇到運行時錯誤。 intqueue_t *intqueue_construct(void) { intqueue_t *queue = malloc(sizeof(int

    0熱度

    1回答

    爲了實現使用循環鏈表的隊列集合,我給了這些結構聲明。 typedef struct intnode { int value; struct intnode *next; } intnode_t; typedef struct { intnode_t *rear; // Points to the node at the tail of the // queue's l

    0熱度

    1回答

    是否有一個選項來檢查隊列是否爲空,並且所有線程已經完成處理其任務(即運行task_done())?我只想在滿足這兩個條件的情況下添加其他任務。 因爲我希望能夠添加更多的任務,我不能只是退出未使用的線程,並使用activeCount()。另外我不想加入()Queue,因爲我希望能夠主動監視執行的進度。 下面是一個例子代碼: from Queue import Queue from threadin