在JavaME中实现阻塞队列:如何优化它？
在JavaME中实现阻塞队列的优化方法：
阻塞队列是一种特殊的队列，它可以在队列为空时阻塞出队操作，在队列已满时阻塞入队操作。在JavaME中，可以使用java.util.concurrent包中的ArrayBlockingQueue来实现阻塞队列。
以下是一些优化阻塞队列的方法：
- 选择合适的队列容量：队列的容量直接影响到阻塞队列的性能。如果队列容量太小，可能会导致生产者和消费者线程频繁地阻塞和唤醒，从而影响性能。如果队列容量太大，可能会导致内存浪费。因此，需要根据实际情况选择合适的队列容量。
- 使用更高效的锁机制：在JavaME中，可以使用java.util.concurrent包中的ReentrantLock来实现更高效的锁机制。ReentrantLock比synchronized关键字更灵活，它可以实现更细粒度的锁，从而减少锁的竞争，提高性能。
- 使用更高效的条件变量：在JavaME中，可以使用java.util.concurrent包中的Condition来实现更高效的条件变量。条件变量可以让线程在等待某个条件满足时阻塞，从而避免CPU的浪费。Condition比使用Object的wait和notify方法更灵活，它可以支持多个条件变量，从而提高性能。
- 使用更高效的数据结构：在JavaME中，可以使用java.util.concurrent包中的ConcurrentLinkedQueue来实现更高效的数据结构。ConcurrentLinkedQueue是一个基于链表的无锁队列，它可以实现非阻塞的入队和出队操作，从而提高性能。
- 使用轻量级线程：在JavaME中，可以使用java.util.concurrent包中的ThreadPoolExecutor来实现轻量级线程。轻量级线程可以减少线程的创建和销毁开销，从而提高性能。
总之，要优化JavaME中的阻塞队列，需要从队列容量、锁机制、条件变量、数据结构和线程池等方面进行考虑，以实现高性能、低延迟的阻塞队列。
相关·内容
2回答
队列的同步
、、、
在我的程序中，我有一个“发送者”和“接收者”线程，这两个线程都作用于一个队列。
我在类中将我的队列定义为：
static Queue<my_class> queue = new LinkedList<my_class>();
然而，我认为我遇到了问题，因为我的Queues没有同步。在我的"Receiver“线程中，有时我必须从队列中删除项目，这将影响"Sender”线程的操作方式。
我正在读关于BlockingQueues的文章，想知道在我的情况下，这是不是我需要使用的东西？如果是这样，我如何更改我的声明？我是否也需要在“发送者”和“接收者”线程中声明B
浏览 2提问于2013-06-04得票数 0
1回答
我有一个函数，它创建一个新的库存项目，并调用一个外部API来生成条形码。如何在函数返回后调用urllib.request.urlretrieve(api_request_url, file_name)，使其不阻塞我的API？
@api.route('/api/inventory/new/<id>', methods=['POST'])
@cross_origin()
def new_inventory(id):
name=request.json['name']
uid=request.json['uid
浏览 2提问于2015-09-15得票数 0
回答已采纳
我正在研究操作系统中的锁定机制，并了解到这些POSIX函数：
pthread_cond_wait(pthread_cond_t *c, pthread_mutex_t *m);
pthread_cond_signal(pthread_cond_t *c);
我完全理解在这里睡觉/醒来背后的想法。但我不确定这是如何在HW中完成的，以及它如何影响scheduling...etc。
我的理解是，当线程执行: pthread_cond_wait()时，它会进入睡眠(块)，但这实际上意味着什么呢？是的，它会被取消调度，并在特权队列的某个位置移动到阻塞状态，但是当另一个进程执行pthread_cond_s
浏览 0提问于2017-09-30得票数 1
回答已采纳
我正在开发一个the抓取工具，它应该对被刮掉的数据执行各种操作。
正因为如此，我需要各种不同的GUI来有序地工作，正因为如此，我需要主要的方法来等待，直到每个人都完成了它的目的。
在搜索了一段时间之后，我发现了以下StackOverflow问题，这些问题提供了一些关于如何解决问题的线索，但我无法实现，因为它们与我的情况有些不同：
我知道我可以使用侦听器触发/GUI组件(例如按钮)的代码，但我很难让主线程等待该侦听器唤醒它，而GUI线程的代码(当有一个线程时)由主线程初始化.
这是一段简化的代码，用来演示程序应该如何工作：
public class Main {
/*
浏览 3提问于2012-08-01得票数 0
我在java中读到了并发队列，并且收到了关于LinkedTransferQueue的混淆。什么是LinkedTransferQueue类型(它是阻塞队列还是非阻塞队列)？我读过LinkedTransferQueue使用CAS (比较和交换)方法和park (比较和交换)方法不安全，并且由节点和指针(如ConcurrentLinkedQueue )组成，它推动了这样的想法，即它是一个非阻塞队列。但是接口TransferQueue扩展了TransferQueue看起来模棱两可。最后，LinkedTransferQueue阻塞还是不阻塞队列？
浏览 3提问于2016-08-03得票数 0
回答已采纳
2回答
java如何执行发件人线程
、、、、
有人告诉我，任何通过输出流(在我的例子中使用tcp/ip )输出的数据都可能被阻塞。在这种情况下，我不希望通过等待数据输出而停止应用程序。
我需要一个如何做这件事的模型。
我需要通过这个流发送消息对象。
我认为我需要一个包含这些消息对象的阻塞队列。线程的run()方法将获取可用的任何消息对象，并将其发送到true。
我的问题是
是否有比一个时间真循环更好的方法来完成这个任务？也许在while真循环中，如果没有消息要发送，我可以告诉yield/sleep.Is线程有一个更好的模型可以使用吗？我担心，如果我的代码中有一段时间(真)，它将占用等待消息的处理器周期。
拜托，有这方面经验的人，告诉我是否
浏览 2提问于2009-07-06得票数 0
1回答
同步队列？
、、、、
我有两个线为一个网络游戏我正在制作。一个线程接收两个X和Y号，另一个线程向登录到服务器的每个人发送X和Y号。基本上，我需要一个队列，它将允许第一个线程向队列中添加一个2D数组，并继续这样做，同时，将数组从队列中取出并删除，用于将数组发送给其他播放器。有办法这样做吗？我知道我需要一个同步队列，但是我如何同步一个队列，这叫做阻塞队列吗？
总的来说，我需要一个同步的队列，这将允许两个线程抛出东西和取出东西。有可能吗？
-Dan
浏览 3提问于2013-01-31得票数 1
3回答
Looper的循环方法在ActivityThread的main方法中调用，并启动一个无限for loop，它在消息队列上迭代。当队列中没有更多消息时，它将调用nativePollOnce方法，该方法等待下一条消息。
所以我的问题是
1.如果等待下一条消息，那么主线程将被阻塞，那么它如何才能使更多的消息队列排队。
2.如果它不被阻塞，那么它将消耗CPU周期，而其他人将没有机会在队列中添加消息。
请考虑MessageQueue、Handler、Looper在主线程和UI事件上，以及由主线程处理的输入事件。
链接
浏览 9提问于2020-05-21得票数 0
1回答
我读过一篇关于使用自定义HTTP1.1服务器为许多客户提供服务的文章。它说，人们需要利用线程池与有CPU内核的线程数量一样多，而不是为每个请求生成一个新线程。但是，假设一个文件是1GB长的。当文件正在传输时，它的传输将停止线程池中的一个队列，从而停止对新请求的处理。在传输这样的文件时，肯定会产生线程吗？但是，应用什么标准来确定是否要生成一个新线程来服务请求、文件大小？还是其他的？也许使用了某种形式的合作多任务处理？
浏览 3提问于2016-10-12得票数 1
回答已采纳
1)创建的ios中的串行队列
_queue = dispatch_queue_create("serial-queue-1", nil);
在主线程或某个不同的线程上运行。
和
2)如果它在主线程上运行，那么如果我们通过以下方式将代码块同步分派到上面的队列
dispatch_sync(_queue, ^{ method1(); method2(); });
当这个队列轮到它时，它会执行完整的代码块吗?或者它也可以离开这个队列，在两者之间执行一些其他的代码？
浏览 0提问于2019-06-12得票数 0
我注意到在收集提交给IExecutorService的任务的结果时存在一些延迟。这只是在试图以期货的形式收集结果时，使用从ExecutorService继承的提交(可调用任务)的上下文。我还发现，当您通过异步回调收集结果时，性能是好的。考虑到期货也是异步的，我试图理解为什么退出results.Is有一个滞后--某种特定于hazelcast工作方式的东西？
此外，如果我使用提交(可调用的任务，ExecutionCallback回调)，我应该期望什么样的行为？我是否应该期望它随机选择一个成员在负载平衡或不进行负载平衡的情况下执行？
编辑：用一些示例代码更新问题。当主线程继续读取未来值时，我会将期货
浏览 1提问于2013-12-19得票数 1
因为最初的JavaMe团队将离开去做其他的项目。JavaMe项目将被一些对JavaMe一无所知的人接管。
过渡期:一个月
关于这个JavaMe项目：
大约35000行代码(超过180个java文件，SourceCode总数为8.5KB )
使用波兰语，Pro卫兵
文档: JavaMe项目本身没有文档。没有UML地图。
我猜困难：
熟悉JavaMe，这应该没问题
以做进一步的发展。我们需要阅读sourceCode --不容易读到35,000行没有足够注释的代码。
100多部电话的适应工作
这些是问题，谢谢！
如果我们的人没有在JavaMe的经验，是不是一个月太仓促了？
以便及时接受这份工作。我们
浏览 0提问于2011-03-10得票数 3
3回答
我在ios中学习并发编程主题。我为多个串行分派队列做了一个示例应用程序。
-(IBAction)SerialDispatchAction:(id)sender
{
s1queue = dispatch_queue_create( "com.newtok.firstQueue" , NULL);
s2queue = dispatch_queue_create( "com.newtok.secondQueue" , NULL);
dispatch_async(s1queue, ^{
int i=0;
wh
浏览 0提问于2012-02-09得票数 1
回答已采纳
2回答
我有一个非常奇怪的情况，我有多个嵌套的分派队列，有时我需要更新UI。如果我已经在主线程上，DispatchQueue.main.async不会执行，如果我跳过它，我可以在调试器中(以及使用Thread.isMainThread)看到我在主线程上，但在一个自定义队列中，并且UI不会更新。如何到达“真正的”主线程(com.apple.main-thread)？或者如何确保通过以下方式创建的队列
private let progressQueue = DispatchQueue(label: "custom_thread", attributes: .concurrent)
一定是后
浏览 48提问于2021-04-15得票数 0
2回答
线程安全异步字节队列
、、、、
我有一个回调方法，每当有新数据可用时都会调用该方法：
public delegate void DataCallback(
byte[] buffer,
int offset,
int count);
我想将它包装在一个实现类似于以下接口的类中：
public interface IDataSource
{
IAsyncResult BeginRead(
byte[] buffer,
int offset,
int size,
TimeSpan timeout,
AsyncCallb
浏览 1提问于2009-05-21得票数 4
1回答
目前我们有LinkedBlockingQueue和ConcurrentLinkedQueue。
LinkedBlockingQueue可以是有界的，但它使用锁。
ConcurrentLinkedQueue不使用锁，但它不是有界的。而且它不会阻塞，这使得它很难轮询。
显然，我不能让一个既阻塞又无锁的队列(等待自由或非阻塞或其他)。我不要求学术上的定义。
有没有人知道一个队列实现，它基本上是无锁的(不在热路径中使用锁)，在空的时候阻塞(不需要忙碌等待)，并且是有界的(满的时候阻塞)？堆外解决方案也是受欢迎的。
我听说过LMAX Disruptor，但它看起来一点也不像队列。
我也很高兴知道非通用的
浏览 0提问于2017-09-29得票数 3
1回答
具有任务并行库的队列
、、、
我对使用.Net TPL框架和一般多线程编程很陌生。我搜索了一些教程和文章，并把下面的解决方案放在一起。
它是一个简单的多线程队列和调度器，它轮询队列并将每个项作为单独的任务处理。
如果你能对解决方案发表评论，指出我做错了什么，或者如何更有效地解决问题，那就太好了。
//Console app that starts the Queue and Scheduler
class Program
{
static void Main(string[] args)
{
Console.WriteLine("Job
浏览 0提问于2014-10-06得票数 2
2回答
我有一个程序(C#)，其中包含要执行的一系列测试。
另外，我有两个线程。一个用于向列表中添加任务，另一个用于从列表中读取和删除已执行的任务。
每次有一个线程想要访问列表时，我都会使用'lock‘函数。
我想做的另一件事是，如果列表为空，则需要读取列表的线程将休眠。并在第一线程将任务添加到列表时唤醒。下面是我写的代码：
...
List<String> myList = new List();
Thread writeThread, readThread;
writeThread = new Thread(write);
writeThread.Start();
readTh
浏览 0提问于2010-04-27得票数 6
回答已采纳
1回答
我需要开发一个比OS复制更快的应用程序，使用一个线程读取源文件，另一个线程编写源文件。源文件和目标文件位于不同的硬盘驱动器中。
我的问题是如何将源读取线程的结果传递到目标写入线程，而不产生某些竞争条件，并保持复制进程的最高性能，以实现比OS复制更快的复制进程。
浏览 2提问于2014-04-17得票数 0
我非常沮丧的是，在Netbeans上安装Java ME并尝试使用java提供的非常重要的类后，它们中的大多数都不能工作！
其他的都是可行的，但是扫描仪？！？没有它我甚至不能工作(请原谅我的双关语)
我的代码：
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
packa
浏览 3提问于2017-09-14得票数 0
我写了一个很好的优先级队列类，
class ConcurrentPriorityQueue<T>
: IProducerConsumerCollection<KeyValuePair<int,T>>, INotifyCollectionChanged
where T : INotifyPropertyChanged
现在我想把它包装在一个BlockingCollection中，
Queue = new ConcurrentPriorityQueue<DownloadItem>(10);
Buffer = new Blocking
浏览 0提问于2010-10-19得票数 2
我希望处理大量的文件，从顶部目录路径开始，并对目录中的每个文件和任何子目录中的任何文件应用转换(例如将char转换为char )。如果顶部目录路径为“/ path / to /目录”，则输出结果将写入路径“/ path /to/目录转换”处的目录。目录的深度和文件的数量可以任意大，1,000级深度和1,000,000个文件。每个输入文件可以任意大，例如100 be的大小。
我首先编写一个从顶层目录开始的递归函数，并使用新的java.io.File(pathToDirectory)创建一个新文件，检查文件是否是文件或目录，并进行转换。
private void applyTransform(Fi
浏览 0提问于2019-08-05得票数 2
我们遇到了一个非常奇怪的问题，我想问一下，是否有人在实践中遇到了同样的问题。
在应用程序中，我们使用AVFoundation实现了最新的苹果自定义摄像头示例。正如我已经说过的，我们已经完全遵循了他们的例子，并以推荐的顺序调用所有阶段，我们所做的唯一改变是我们将摄像头管理分离到一个单独的类中，但我们已经提供了足够的交互接口。
包含相机预览视图的ViewController可能会导致另外两个标准屏幕，这两个屏幕不需要太多时间进行初始化(至少它不可见)。转换通过NavigationController进行。
在我们的测试中，在调试模式下，通过Testflight和HockeyApp (最后两个是Ad
浏览 0提问于2014-08-18得票数 2
2回答
下面的代码
DispatchQueue.main.async {
print(Thread.current)
DispatchQueue.global().sync {
print(Thread.current)
}
}
打印
<_NSMainThread: 0x60000059c140>{number = 1, name = main}
<_NSMainThread: 0x60000059c140>{number = 1, name = main}
从技术上讲，全局队列会找到一个空闲线程来运行任务，该线程可能是主线程。
添加到全
浏览 33提问于2021-09-24得票数 1
1回答
我今天已经发布了一个问题。这个问题是关于同一个项目的，但并不相关。我正在为乐高NXT Mindstorm机器人开发一个应用程序。我有两个机器人和一个运行在PC上的GUI。
在leJOS NXJ中，您只能使用一个输入读取器。这意味着您不能将PC直接连接到两个机器人，并让这两个机器人直接相互连接。这就是我所做的。我已经将PC直接连接到两个机器人，当两个机器人想要直接通信时，我通过GUI发送它们的消息。
在GUI和机器人之间以及机器人本身之间有大量的通信。由于这个原因，每当我向输出流写入数据时，似乎有些数据被其他数据覆盖，系统无法正常工作。
有人建议我写一个类来保存一个集合(队列)对象，这样每当机器
浏览 4提问于2010-07-29得票数 0
2回答
我有一个处理作业的Windows服务。此服务中的作业是一系列操作，例如：
-> B -> C -> D -> E
每项工作都应该完全独立于其他工作。当前的实现在自己的线程(在本例中是new System.Threading.Thread)上处理每个作业，这在大多数情况下都能很好地工作。但是，事实证明B操作不是线程安全的，两个线程不应该同时处理B操作。如果两个线程同时尝试执行B操作，有时会发生奇怪的结果或错误。请注意，其他操作可以由多个作业同时执行，不会产生任何不良影响。
与其试图以线程安全的方式重新实现B操作(我预计这将需要大量资源来实现和测试)，我只想一次将每
浏览 1提问于2013-01-03得票数 2
回答已采纳
3回答
本例的最佳编程实践是什么：
我有一个带有文件对象的链接列表，偶尔会将传入的文件对象添加到这个列表(AddThread)中。
这些文件对象需要被“处理”，应该是由另一个线程(ProcessThread)来处理。因此，每当将文件对象添加到列表中时，都需要一次处理一个文件对象，而其他文件对象仍然可以添加到列表中。
在处理过程中，从列表中读取一项，然后从该列表中删除。处理在列表为空时停止，如果添加新项，则再次启动。
我如何看待它：：
每当更改应用到列表(添加的项)时，就会触发更改事件。这个事件唤醒了ProcessThread。ProcessThreads将列表锁定一小段时间来读取它，然后再次释放锁。当
浏览 2提问于2012-02-08得票数 0
回答已采纳
我正在开发一个在OpenCL中实现递归射线跟踪的程序。要运行内核，我必须选择设备:与系统集成的英特尔设备和Nvidia GeForce图形卡。
当我使用第一个设备运行项目时，没有问题；它正确运行，并显示了算法的结果。
但是当我尝试使用Nvidia设备运行它时，它会崩溃在具有同步缓冲区映射的回调函数中。
代码中崩溃的部分如下：
clEnqueueNDRangeKernel( queue, kernel, 1, NULL, &global_work_size, NULL, 0, NULL, NULL);
// 7. Look at the results via synchronou
浏览 4提问于2016-08-19得票数 1
我需要将几个在一个NSOperation中进行网络调用的NSOperationQueue链接在一起，然后等待所有这些都完成。
我将所有的NSOperation添加到我的NSOperationQueue中，然后调用operationQueue.waitUntilAllOperationsAreFinished()。这是可行的，但它会无限期地等待，因为NSOperations中的回调将操作的状态设置为“已完成”，因此不会调用。
我使用以下NSOperation子类：
class ConcurrentOperation: NSOperation
{
enum State: String
浏览 0提问于2016-04-17得票数 0
回答已采纳
1回答
我偶然发现了一个特定的例子，其中模块化和简单性似乎是相互冲突的。通常情况并非如此，所以我真的不知道如何解决这个问题。
假设我想创建一个queue接口：
template<typename T>
class queue {
public:
virtual ~queue() {}
virtual void enqueue(const T& t) = 0;
virtual void enqueue(T&& t) = 0;
virtual T dequeue() = 0;
};
当我正在进行几个实现(其中一些是原子实现)时，我注意到我可以通过使用一
浏览 0提问于2014-08-02得票数 2
回答已采纳
我们需要并行运行任务，所以我们使用spring @Async特性。为了提供executor配置，我们创建了一个Executor bean。
@Bean(name = "async")
public Executor threadPoolTaskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(2);
executor.setMaxPoolSize(2);
浏览 22提问于2020-09-21得票数 0
我需要为我的爬虫“序列化”一个包含domanis名称(Strings(对象))的大型BlockingQueue( 10_000) --例如，如果我停止它，或者它会意外发生--这将有助于不爬行已经完成的操作。做这件事最好的方法是什么？在NET中，我已经将二进制序列化用于这样的任务(例如，protobuf )(它更快、更序列化，信息可视化对于理解-so并不重要，而不是必需的XML )。但是如何在java中做到这一点呢？你可能是样本的推荐人吗？
浏览 0提问于2014-09-08得票数 4
回答已采纳
当涉及到多线程系统的队列实现时，我经历了一些意外。以下是：-
场景：-1生产者，1消费者：-生产者将整数放入队列中。使用者只需将其从队列中移除。
队列的底层数据结构：- TreeSet (我从未想过要使用)、LinkedList、LinkedBlockingQueue(大小不定)
代码：- of TreeSet作为队列：-
while (i < 2000000) {
synchronized (objQueue) {
if (!(objQueue.size() > 0)) {
try {
浏览 4提问于2012-07-22得票数 16
1回答
如何在Java ME中使用用户界面(GUI)？我遵循了一些教程，它们都指向javax.microedition.lcdui包，但它并不存在于JavaME8SDK中。
因为我找不到这个包，而SDK 3.4在Netbeans中给出了错误(我激活了它并将其添加为平台，但当我在创建项目时必须选择一个模拟平台时，它不会出现。
您可以在这里看到我为什么没有LCDUI包：
为了在这个Java版本中使用GUI，我需要一些帮助。
谢谢。
浏览 0提问于2015-12-09得票数 2
我有一个运行弹球机的Python应用程序。它需要运行一个相当一致的循环速度来做弹球类型的事情，但我也需要能够加载图像和声音在整个游戏的各个点。我没有足够的内存预加载整个游戏所需的所有声音文件，所以我想使用一个额外的线程(或线程)在后台加载它们，而主游戏循环继续进行。
使用Python的threading模块非常容易，使用Queue.Queue来维护需要加载的资产列表也是如此。我的问题是，让资产加载程序线程始终运行是"ok“(因为没有更好的词)，还是应该在需要时创建线程，然后让它在我完成时结束。在我的例子中，弹球机器--和我的Python应用程序--一次运行几个小时(或几天)。
我发现的
浏览 2提问于2015-02-17得票数 0
回答已采纳
2回答
我有数据结构(即队列、堆栈或列表)。有无限循环(在线程1中)将对象插入到该数据结构中，还有另一个无限循环(在线程2中)，它从该数据结构中获取对象并对其进行一些处理。我不希望处理循环阻止insert循环。
如何在Java中正确地实现这一点，以便在具有同步和来自两个不同线程的并发读写的两个线程之间共享一个单一的数据结构？java并发API (java 7)中是否有我可以使用的数据结构？是否有解决这个问题的建议？
浏览 0提问于2015-11-30得票数 0
回答已采纳
我在Azure上运行服务总线，每秒10到100条消息，。
最近，我切换到了.net 4.5，所有的代码都很兴奋地重构了所有代码，使‘异步’和‘等待’在每一行中至少进行了两次，以确保它已经完成了“正确”:)
现在，我想知道这究竟是为了更好还是更糟，。如果你能看一看代码片段，让我知道你的想法。我特别担心的是，如果线程上下文切换并没有给我带来更多的悲伤而不是好处，从所有的异步.(看！垃圾堆，这绝对是一个因素)
我将发布两个方法-一个在ConcurrentQueue上执行while循环，等待新消息，另一个方法每次发送一个消息。我还使用了完全符合Azure博士规定的瞬态故障处理块。
发送循环(从开始时开
浏览 4提问于2013-03-25得票数 6
回答已采纳
1回答
我在用龙卷风。我希望下面的代码很容易理解，它产生了一个tcproute进程，并将输出发送到websocket的另一端。
class TracerouteHandler(tornado.websocket.WebSocketHandler):
def open(self,ip):
p = subprocess.Popen(['traceroute',ip],stdout=subprocess.PIPE, stderr=subprocess.PIPE)
while p.poll() is None: #running
line=p.stdout.re
浏览 1提问于2012-11-06得票数 3
我正在尝试开发一个使用 ( web框架)的应用程序，我需要在后台处理一些东西(异步)，这样我就不会阻塞用户。
为此，我正在考虑使用ThreadPoolExecutor。有没有一种方法可以保存队列，稍后恢复？(可能应用程序被停止/重新启动，而队列中仍有项目)。
另外，您如何向用户报告进度(挂起、进行中、完成)？
基本上，我正在寻找的是类似于的东西，但对于Java，它需要嵌入到我的应用程序中，这样用户就不需要安装额外的服务。
浏览 1提问于2015-12-24得票数 0
1回答
我正在寻找一个Java调度框架，它不是定时器驱动的，也不是任何cron风格的调度器，比如Quartz和其他。这里有太多关于定时器驱动的调度器的问题和答案，但是这样的调度器不会解决我的问题。
我遇到的问题是，我有几个线程，每个线程都从分配给它的阻塞队列中获取消息。当阻塞队列为空时，从该队列读取的线程将被阻塞，并且不能被分配给其他线程。这样，我的系统可能会遇到一些饥饿问题。因此，JDK5线程池将无法适应，因为它们只能将未被阻塞的空闲线程分配给另一个需要服务的队列。
我在互联网上发现了hawt调度，这是我非常需要的，但它的高级功能，如期货，将使我的事情更舒适，只有在使用Scala API时才能使用。
浏览 1提问于2012-09-02得票数 0
1回答
我已经实现了一个UDP接收器，它不断地接收DTN数据包(UDP封装)并对它们执行一些操作。整个过程是在一个主线程上工作的。然而，这会消耗处理数据包的时间，并在发送者发送大量数据时导致数据包丢失。
int main(int argc, char *argv[])
{
while(1)
{
std::vector<char> data(64535);
size_t len = sock->recvfrom(&data[0], maxlen, 0, fromAddress);
// perform operat
浏览 0提问于2019-03-19得票数 0
回答已采纳
5回答
java中的无限fifo
、、、
我正在寻找一种线程安全的无限阻塞fifo，它由固定的缓冲区支持，如数组。语义是多个读取器和写入器线程可以安全地访问它。如果缓冲区已满，写入器将阻塞并覆盖最旧的项。如果缓冲区为空，则读取器阻塞。当total and和total removed的计数器一次或多次绕过内部缓冲区大小时，必须保持Fifo排序。
有趣的是，我通常会寻找的地方(java自己的并发集合、commons集合、芭乐)都看不到对这种“显而易见”的需求有一个即时的答案。
浏览 0提问于2013-02-18得票数 0
回答已采纳
1回答
使类线程安全
、、、
生成此代码是为了在我的应用程序中保存事件历史记录，因为我需要提供以下代码：
public class LogDataBase {
public LogDataBase(Context context) {
try {
this.context = context;
String logPath = context.getFilesDir() + logStoragePath;
file = new File(logPath);
if (!file.exists()) {
浏览 0提问于2014-01-10得票数 0
我正在尝试理解java多线程，而且我在让这个线程完成它的运行方法时遇到了一些困难。
我有两个工作线程在使用阻塞队列中的消息。他们应该对传递的值做一些简单的操作，并将结果附加到文件中。因为我不想为每个I/O操作打开一个文件读取器，所以我想使用一个StringBuilder逐步构建报告，并在线程被踢出它的主循环时编写它。然而，循环后的代码似乎从未运行过。
下面是线程中运行的代码：
@Override
public void run() {
StringBuilder builder = new StringBuilder();
while(true) {
if
浏览 0提问于2016-03-10得票数 2
回答已采纳
我已经编写了一个基于Python的守护进程，它根据某些参数阻止恶意IP。现在，我想自动解除(删除规则)的IP 1小时后，但不知道如何使用计时器/调度模块与我的代码。
我知道另一种方法可以是：
Fail2ban
ipset超时
iptables -m -最近--秒开关
cron作业
但我有局限性，不能使用上面提到的替代方法。
我的主要代码在一段时间内运行(1)循环，所以它的阻塞IP。如何在我的python代码中创建一个并行模块/函数来执行IPTABLES -D 命令以删除IP？每个IP都有自己的特定时间来解除阻塞。
例如：
IP1
IP2
IP3
更新
浏览 4提问于2017-10-12得票数 0
1回答
有锁队列与无锁队列
、、、、
我参与了一项侦听web服务的任务。它将通过推送服务发送xml数据。数据必须经过一些计算，然后我们才能显示出来。
我计划通过服务监听器使用queue来存储数据，通过业务逻辑代码来读取数据。它是一个纯粹的单生产者单消费者队列。
由于我必须以web服务推送的形式接收数据，因此我必须始终打开以接收数据并将其推送到队列。我想过使用boost_lockfree_spsc_queue。因为，如果它是一个可锁队列，侦听器必须等待一段时间才能获得锁，而boost_lockfree_spsc_queue不需要任何锁。
我要存储的数据是
struct MemoryStruct {
char *memory;
浏览 0提问于2016-12-06得票数 0
2回答
我想知道我对下面的代码示例是正确的。我有两个线程在java。Thread_W and Thread_R 都可以访问 Queue<String> queue。
在Thread_W中有一个名为put的方法。
private void put(String email){
queue.offer(email);
}
在Thread_R中，有一个名为get的方法，它在Thread_R启动时被调用一次。
public void get(){
while(true)
{
if(!queue.isEmpty())
{
String to = queue.poll()
浏览 6提问于2015-02-10得票数 0
对于Java语言中的元素，queue.add( ArrayBlockingQueue )会锁定它所在的线程吗？我有一个运行着几十个线程的应用程序，所有这些线程都会将信息放入一个ArrayBlockingQueue中。线程不能被锁定很短的时间。如果它们都将对象放入队列中，add方法会立即移动并让队列在将来将对象放入自身，还是等到它实际放入队列中？
浏览 21提问于2018-01-11得票数 0
4回答
我有6个线程在我的应用程序中持续运行。场景是：
一个线程不断地获取消息并插入到消息队列中。其他4个线程可以看作是不断地从队列中获取消息并对其进行处理的工作者。另一个最后一个线程填充分析信息。
问题：
现在获取消息线程的休眠持续时间是100ms。工作线程数为200ms。当我运行这个应用程序时，消息获取线程正在控制并插入到队列中，从而增加了堆。工作线程没有机会处理消息并释放它们。最后它会导致内存不足。
如何管理这种情况，以便为消息获取线程和工作线程提供平等的机会。
提前感谢:)
浏览 0提问于2012-12-19得票数 1
回答已采纳
4回答
目前，我有一个算法，看起来有点像网页蜘蛛或文件搜索系统，它有一个元素集合来处理，处理元素可以导致排队更多的元素。
但是，这个算法是单线程的--这是因为我从db中获取数据，并且希望一次只有一个db连接。在我目前的情况下，性能并不重要--我这样做只是为了可视化，以简化调试。
对我来说，使用队列抽象似乎很自然，但是使用队列似乎意味着多线程--据我所知，大多数标准的java队列实现驻留在java.util.concurrent包中。
我知道我可以继续使用任何支持拉和推的数据结构，但是我想知道在这种情况下使用哪种数据结构更自然(在单个线程应用程序中使用队列可以吗？)
浏览 10提问于2012-06-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
