thread-safety

    1熱度

    1回答

    Keras新手在這裏。我在一個非常大的CSV文件上做了一些深入的學習實驗(keras 2.x,tensorflow作爲背景,python3.5)。 將CSV加載到Pandas數據框後,我需要讀取數據幀以將數據轉換爲X_train,y_train/label。因爲轉換後的X_train非常大,不適合內存。我開始使用generator和model.fit_generator()。我已經瞭解到,通過創建

    0熱度

    1回答

    我從Thread.run()以前打開的某個線程打開ProgressDialog。問題是ProgressDialog僅在select_language_by_user()函數完全完成其代碼之後才顯示。 看起來我在調用select_language_by_user()之後有一些暫停,並且在完成之後它會立即打開ProgressDialog和新的Activity。 我嘗試用戶runOnUiThread()

    2熱度

    1回答

    無法理解一本書中來自apress的示例,它講述了TPL中帶有任務構造的threadlocal的濫用案例。 爲什麼預期的結果不是10000呢? 任何人都可以給出一個更詳細的解釋下面的程序的程序流,其中行立即執行和一些行異步的時間?執行的順序和順序? using System; using System.Threading; using System.Threading.Tasks; name

    1熱度

    2回答

    可以說我有以下幾點: struct Foo { Foo() : bar([&]{ doSomething();}) std::function<void(void)> bar; void doSomething(){}; } 而且可以說,一個線程調用經常一個Foo實例的杆件,而另一個線程自毀foo的實例。因爲Foo的析構函數被首先調用,所以調用bar會導致無效

    0熱度

    2回答

    在剛剛添加的同步到大多數方法的時刻,因爲看起來沒有它,這些方法不是線程安全的。還有什麼我需要實現以確保它是線程安全的。 此外,有沒有更好的方式去做這件事。當時只有一個線程可以同時使用循環隊列,這似乎有點低效。 class CircularQueue<T> implements Iterable<T>{ private T queue[]; private int head, t

    1熱度

    1回答

    我是Rust的新主題。我正在努力通過線程內的rustbox箱的RustBox type。 欲按q鑰匙,而且它在顯示2秒鐘一個+符號(1,1),而予壓瓦特那些2秒內鍵,其示出了另一+在(1,2符號)。 我寫了相同的邏輯一些代碼: extern crate rustbox; use std::thread; use std::time::Duration; use rustbox::{Col

    0熱度

    1回答

    我已閱讀,發佈/訂閱機制是從一個線程傳遞到GUI(https://www.blog.pythonlibrary.org/2010/05/22/wxpython-and-threads/)以下 程序的線程安全的意思,它已經從一個更大的問題的實質減少,從線到wx.TextCtrl區域通過發佈/訂閱機制的GUI的一些著作後崩潰。爲了試驗幾個寫入率,可以在time.sleep(x)聲明中更改它。無論x是,

    -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() {

    9熱度

    2回答

    我有一個類,我在updateLiveSockets()方法內每隔30秒從單個後臺線程填充地圖liveSocketsByDatacenter,然後我有一個方法getNextSocket()將被調用多個閱讀器線程來獲取可用的活動套接字,它使用相同的地圖來獲取此信息。 public class SocketManager { private static final Random random

    0熱度

    2回答

    我有一個下面的方法,它被多個線程同時調用來獲取活動套接字。它需要LinkedBlockingQueue作爲參數,然後我迭代,看看是否有liveSocket可用,如果它可用,然後我刪除並返回該套接字。 private Optional<Holder> getSocket(final LinkedBlockingQueue<Holder> endPoints) { Optional<Hold