Tag: multithreading

RabbitMQ的例子：多个线程，通道和队列

我刚刚阅读了RabbitMQ的Java API文档 ，发现它非常翔实和直接。 如何设置一个简单的发布/消费Channel的例子很容易理解。 但这是一个非常简单/基本的例子，它给我留下了一个重要的问题： 我如何设置1 +多个Channels来发布/消费多个队列？ 比方说，我有一个RabbitMQ服务器上有3个队列： logging ， security_events和customer_orders 。 所以我们要么需要一个Channel才能够发布/使用所有3个队列，或者更有可能有3个独立的Channels ，每个Channels专用于一个队列。 最重要的是，RabbitMQ的最佳实践规定我们为每个消费者线程设置1个Channel 。 对于这个例子，假设security_events只有一个消费者线程，但是logging和customer_order都需要5个线程来处理这个卷。 所以，如果我理解正确，那是否意味着我们需要： 1个Channel和1个消费者线程，用于发布/消费security_events ; 和 5个Channels和5个消费者线程，用于发布/消耗logging ; 和 5个Channels和5个消费者线索用于发布/消费customer_orders ？ 如果我的理解被误导了，请先纠正我。 无论哪种方式，一些厌倦了RabbitMQ的老手能帮助我用一个体面的代码示例“连接点”来设置符合我的要求的出版商/消费者吗？ 提前致谢！

什么可能是RejectedExecutionException的原因

我得到这个exception在我的tomcat服务器（+ liferay） java.util.concurrent.RejectedExecutionException 我的课是这样的： public class SingleExecutor extends ThreadPoolExecutor { public SingleExecutor(){ super(1, 1,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>()); } @Override public void execute(Runnable command) { if(command instanceof AccessLogInsert){ AccessLogInsert ali = (AccessLogInsert)command; ali.setConn(conn); ali.setPs(ps); } super.execute(command); } } 我在super.execute(command);行上得到这个exceptionsuper.execute(command); 当队列已满但LinkedBlockingQueue大小为2 ^ 31时，会发生此错误，并且我确信没有太多的命令在等待。 一开始一切都很稳定，但是我重新部署了一场战争之后就开始发生了。 这个类不是战争的一部分，而是在tomcat / lib的jar中。 你有什么想法为什么发生这种情况，以及如何解决它？

线程和等待条件

我正在学习pthread和等待条件。 据我所知，一个典型的等待线程是这样的： pthread_mutex_lock(&m); while(!condition) pthread_cond_wait(&cond, &m); // Thread stuff here pthread_mutex_unlock(&m); 我不明白的是为什么即使我使用pthread_cond_signal()来唤醒线程， while(!condition)也是必需的。 我可以理解，如果我使用pthread_cond_broadcast()我需要testing条件，因为我唤醒了所有等待的线程，其中一个可以使条件再次解锁之前的虚假（从而转移到另一个应执行在那一刻执行）。 但是，如果我使用pthread_cond_signal()我只唤醒一个线程，所以条件必须是真实的。 所以代码可能是这样的： pthread_mutex_lock(&m); pthread_cond_wait(&cond, &m); // Thread stuff here pthread_mutex_unlock(&m); 我读了一些关于可能发生的虚假信号。 这（是唯一的）这个原因吗？ 为什么我应该有虚假singnals？ 或者还有别的东西我不明白 我假设信号代码是这样的： pthread_mutex_lock(&m); condition = true; pthread_cond_signal(&cond); // Should wake up *one* thread pthread_mutex_unlock(&m);

在朱莉娅平行。 function和限制

在他们的arXiv论文中 ，朱莉娅的原作者提到了以下内容： 2.14 Parallelism 。 并行执行由标准库中的Julia实现的基于消息的多处理系统提供。 语言devise通过提供对称协程来支持这样的库的实现，对称协程也可以被认为是协作调度的线程。 此function允许在库中隐藏asynchronous通信，而不需要用户设置callback。 Julia目前不支持本地线程，这是一个限制，但是具有避免同步使用共享内存的复杂性的优点。 这是什么意思，说朱莉娅不支持本地线程 ？ 什么是本地线程？ 其他解释型语言如Python或R是否支持这种并行性？ 朱莉娅独自一人在这？

确保线程池中的任务执行顺序

我一直在阅读有关线程池模式，我似乎无法find以下问题的通常解决scheme。 我有时想让任务连续执行。 例如，我从文件中读取文本块，出于某种原因，我需要按照该顺序处理块。 所以基本上我想要消除一些任务的并发性。 考虑这种情况，带*的任务需要按照它们的顺序进行处理。其他任务可以按任意顺序处理。 push task1 push task2 push task3 * push task4 * push task5 push task6 * …. and so on 在一个线程池的上下文中，没有这个约束，一个待处理任务的队列工作正常，但是在这里显然没有。 我想过让一些线程在一个线程特定的队列上运行，其他的在“全局”队列上运行。 然后，为了连续执行一些任务，我只需将它们推送到单个线程所在的队列中。 这听起来有点笨拙。 所以，在这个漫长的故事中真正的问题是：你将如何解决这个问题？ 你将如何确保这些任务是有序的 ？ 编辑 作为一个更普遍的问题，假设上面的情况变成了 push task1 push task2 ** push task3 * push task4 * push task5 push task6 * push task7 ** push task8 * […]

Android – 防止启动时出现白屏

众所周知，许多Android应用程序在第一个Activity聚焦之前，会非常简短地显示白色屏幕。 在以下情况下会出现此问题： 扩展全局Application类并在其中执行重要的初始化的Android应用程序。 Application对象总是在第一个Activity （在debugging器中可以观察的事实）之前创build的，所以这是有道理的。 这是我的情况延误的原因。 在启animation面之前显示默认预览窗口的Android应用程序。 设置android:windowDisablePreview = "true"显然不起作用。 我也不能将闪屏的父主题设置为Theme.Holo.NoActionBar ，因为[不幸]我的闪屏使用了一个ActionBar 。 同时，不扩展Application类的Application 不会在启动时显示白屏。 事情是，理想情况下， 在显示第一个Activity 之前 ，需要在Application对象中执行初始化。 所以我的问题是，如何在不使用Application对象的情况下对应用程序启动执行这些初始化？ 可能使用Thread或Service ，我想？ 这是一个值得思考的有趣的问题。 我不能绕过它通常的方式（通过设置NoActionBar主题），不幸的是我的飞溅屏幕实际上有一个ActionBar由于一些不相关的原因。 注意： 我已经提到以下问题： 如何修复应用程序的白屏启动？ Android的初始屏幕是白色的？ 在splashscreen之前的白色屏幕 Android应用程序启动时的白色背景 为什么开始在Android中运行应用程序时出现白屏1秒？ 参考文献： 模式 – 启动屏幕 。 品牌启动屏幕：Android的新飞溅 。 飞溅屏幕正确的方式 。

System.Timers.Timer / Threading.Timer与线程与WhileLoop + Thread.Sleep的周期性任务

在我的应用程序中，我必须定期发送心跳到“兄弟”应用程序。 使用System.Timers.Timer / Threading.Timer或使用带有while循环和Thread.Sleep的线程可以更好地完成这项工作吗？ 心跳间隔是1秒。 while(!exit) { //do work Thread.Sleep(1000); } 要么 myTimer.Start( () => { //do work }, 1000); //pseudo code (not actual syntax)…

处理BackGroundWorker的正确方法

这将是一个正确的方式来处置BackGroundWorker？ 我不确定在调用.Dispose（）之前是否需要删除事件。 也是调用.Dispose（）里面的RunWorkerCompleted委托可以做？ public void RunProcessAsync(DateTime dumpDate) { BackgroundWorker worker = new BackgroundWorker(); worker.RunWorkerCompleted += new RunWorkerCompletedEventHandler(worker_RunWorkerCompleted); worker.DoWork += new DoWorkEventHandler(worker_DoWork); worker.RunWorkerAsync(dumpDate); } void worker_DoWork(object sender, DoWorkEventArgs e) { // Do Work here } void worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) { BackgroundWorker worker = sender as BackgroundWorker; worker.RunWorkerCompleted -= new RunWorkerCompletedEventHandler(worker_RunWorkerCompleted); worker.DoWork -= new DoWorkEventHandler(worker_DoWork); worker.Dispose(); […]

如何获得UI线程调度程序？

当没有任何UI元素的引用时，有什么办法可以获得UI线程的Dispatcher ？

WAIT和BLOCKED线程状态之间的区别

线程状态WAIT和线程状态BLOCKED有什么区别？ Thread.State文档 ： 阻止 阻塞等待监视器locking的线程处于此状态。 等候 无限期地等待另一个线程执行特定动作的线程处于这种状态 没有向我解释这个区别。