java-threads

0热度

1回答

我有一个for循环创建了几个AsyncTasks。存在大量的data，for循环处理每个数据并使用该数据调用执行程序。 AsyncTask对这些数据做了一些深入的处理，这些代码对于小数据集来说工作得非常好，即数据数组足够小以至于不会创建太多的线程。 for(Data datum: data) { new SomeAsyncDataTask(datum, this).executeOnE

1热度

1回答

OCJP转储线程同步方法

嗨我正在SCJP转储，但现在我有一个问题。这里是问题： void waitForSignal(){ Object obj = new Object(); synchronized(Thread.currentThread()){ obj.wait(); obj.notify(); } } 哪一种说法是正确的？ A.此代码可以抛出一个Int

-2热度

1回答

OCJP Dumps Thread

任何人都可以帮助我解决以下问题吗？ public class Starter extends Thread{ private int x=2; public static void main(String[] args) throws Exception{ new Starter().makeItSo(); } public Starter(){

1热度

3回答

简单的Ping Pong Java线程

我正在尝试使2个线程一个Ping和一个Pong。这个想法是Ping应该始终执行。我正在使用同步方法。我不确定这里的代码有什么问题。它看起来像它应该工作。我已经阅读了很多文档。所以如果你有任何你认为会有帮助的东西，我会很乐意阅读它。我相信这很简单。任何帮助表示赞赏 class Ping extends Thread { private Table table; private S

0热度

1回答

转换为ExecutorService的

我有其中消费者/生产者程序：将被处理项（字符串）进入一个的BlockingQueue 我实例化来自BlockingQueue的执行取（）的螺纹固定数量的然后处理这些字符串。的处理线程是这个类的实例： class ProcessingThread extends Thread { private void process(String s) { (big method w

0热度

1回答

为什么使用线程来调用类的构造函数？

我在阅读JMS书时遇到了一个问题。以下是代码。我的问题是与线程有关，所以我删除了不必要的JMS代码。 public class MessageConsumer implements MessageListener{ public MessageConsumer(){ //Constructor //configure JMS Connections } @Override

1热度

1回答

3高频率运行的线程使用相同的变量

我正在开发一个android应用程序，它在高频率接收来自ble通知的数据，在屏幕上打印数据并将数据发送到其他外围设备。这是我的情况： onCharacteristicChanged回调接收称为 “值”一个字节数组为10Hz并且在一些浮动解包数据和int变量具有相关联的处理程序handlerThread每30hz启动一次Runnable 。这可运行使用从值解压的变量，在一些变量和sendbro

0热度

2回答

使用ThreadPool按顺序执行类似任务

我想要一个ThreadPool执行客户订单，多个订单应该被并行处理，但是对于相同的客户订单应该按照生成的顺序进行处理。这意味着如果有任何线程已经处理了customerA订单，那么没有其他线程可以处理CustomerA的下一个订单，直到处理完第一个订单。是否有任何ThreadPool实现为我的情况提供服务？

1热度

1回答

ExecutorCompletionService等待最多n秒完成

我正在使用ExecutorCompletionService提交几个任务。然后我想等待最长时间，例如5秒，然后停止处理。 ExecutorService executorService = Executors.newFixedThreadPool(10); CompletionService<String> completionService = new ExecutorCompletionS

1热度

3回答

为什么我的多线程程序按顺序执行？

以下程序不应该按顺序执行，但它仍在执行。 class A extends Thread { public void run() { for(int i=0; i<=5; i++) { System.out.println("Thread A : "+i); } System.out.println("exit f