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