multithreading

    -1熱度

    1回答

    林試圖找出爲什麼這個心不是「線程安全」和IM畫坯公共 public class Counter { private static int val = 0; public Counter() { } public static void set(int newVal) { val = newVal; } public static void decrement() {

    0熱度

    3回答

    在下面的代碼中,在線程運行increment方法後,它將值2輸出到控制檯。不應該將值設爲1,因爲方法用1遞增? class TestSync implements Runnable { private int balance; public void run() { for(int i = 0; i < 50; i++){ increment(); Sy

    0熱度

    1回答

    我打電話給一個API來獲取ID列表。該列表包含大約55.000個ID。然後,我希望啓動線程並根據ID獲取有關其對象的信息並將其存儲在數據庫中。我設法使用線程來做到這一點,但想知道如何使用線程池來優化它。我想要做的10個線程,將它們添加到一個線程池,等待它們完成,等待10秒(或我會得到429,太多的請求),然後再開始10個線程,直到所有完成。爲了做到這一點,需要做些什麼? 此外,該列表的長度未知,因

    0熱度

    1回答

    我想了解Spark中的分區。 我在Windows 10本地模式下運行spark。 我的筆記本電腦有2個物理內核和4個邏輯內核。 1 /術語:對我來說,spark =核心線程。所以Spark中的核心與物理核心不同,對吧? Spark核心與任務相關聯,對嗎? 如果是這樣,因爲你需要一個分區線程,如果我的sparksql數據框有4個分區,它需要4個線程嗎? 2 /如果我有4個邏輯內核,是否意味着我只能在

    0熱度

    2回答

    我現在閱讀在Java中思考,有關同步的章節,有一個我無法理解的例子。 public abstract class IntGenerator { private volatile boolean canceled = false; public abstract int next(); public void cancel() { canceled =

    2熱度

    2回答

    我想實現一個簡單的多線程TCP服務器。當只有一個連接的客戶端時,它運行良好,但當同時連接兩個客戶端時,第一個客戶端的線程有時會收到必須由第二個客戶端接收的消息。如何處理他的問題? class ClientThread(Thread): def __init__(self, ip, port): Thread.__init__(self) self.ip = ip

    2熱度

    1回答

    我是python的初學者,我在做一個簡單的python遊戲。我試圖解決以下錯誤RuntimeError: threads can only be started once 我試圖.cancel()計時器,但已經似乎沒有工作,我已經做了一個if語句,看看計時器.is_alive執行前。控制檯拋出錯誤送行ball_char = play_timer.start() def playball(state

    -1熱度

    1回答

    我有一個函數,可以獲取我選擇使用financial google的任何貨幣的當前價格,我想多線程,因此我可以單獨發送任何請求。 這裏是我的代碼: def currency_converter(amount, currency): url = 'https://finance.google.com/finance/converter?a={}&from=KGS&to={}&meta=ei%

    2熱度

    1回答

    最近幾天我一直在使用JavaFX,FXML,任務和屬性進行實驗。我偶然發現了一種奇怪的行爲,希望你能幫助我更好地理解發生了什麼。 我有一個簡約的GUI,看起來像這樣:GUI 如果我按一下按鈕創建並啓動了新的任務。此任務將增加一個雙重屬性,並將新值寫入標籤並在ProgressBar中進行設置。任務的代碼可以在這裏看到: public class TestTask extends Task<Void>

    0熱度

    1回答

    我現在閱讀在Java中思考關於原子性和可見性的章節。有一個我不明白的例子。 public class SerialNumberGenerator { private static volatile int serialNumber = 0; public static int nextSerialNumber() { return serialNumber++;