更新存储在阻塞优先级队列中的自定义对象

发布于 2024-10-28 02:27:16 字数 659 浏览 2 评论 0原文

我有一个阻塞优先级队列，它存储消息类型的对象，消息有 String[] data = new String[10]。现在我必须迭代整个阻塞队列，检查其对象消息的第二个元素是否等于传入消息的第六个元素。

Messages 的比较器不是基于需要更新的第 6 个元素。问题是，如果我取出一个对象，那么如何将它放在相同的位置，如果我使用下面的代码来更新它，那么每当运行 iter.next() 时，它可能会开始指向下一个对象。

这就是我正在尝试的。

public synchronized void updateAck(Message ackMessage)
    {
        Iterator iter  = localQ.iterator(); // localQ is the blocking priority queue here
        while(iter.hasNext())
        {
            if(((Message)iter.next()).data[2].equalsIgnoreCase(ackMessage.data[6]))
            {
                (Integer.parseInt((Message)iter.next()).data[6])+1);

            }
        }
    }

原文

I have a blocking priority queue which stores Objects of type Message, message has String[] data = new String[10]. Now I have to iterate over whole blocking Queue, check if its Object message's 2nd element is equal to 6th element of an incoming message.

The comparator of Messages is not based on 6th element which needs to be updated. Problem is that if I take out an object then how to put it at same position and if I use the code below to update it then anytime iter.next() is run it may start pointing to next Object.

Here is what I am trying.

public synchronized void updateAck(Message ackMessage)
    {
        Iterator iter  = localQ.iterator(); // localQ is the blocking priority queue here
        while(iter.hasNext())
        {
            if(((Message)iter.next()).data[2].equalsIgnoreCase(ackMessage.data[6]))
            {
                (Integer.parseInt((Message)iter.next()).data[6])+1);

            }
        }
    }

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

久隐师 2024-11-04 02:27:16

不要在 if 条件中直接使用 (Message)iter.next()，而是尝试这样做。

Message queMessage = (Message)iter.next();

完整代码

 while(iter.hasNext())
{

    Message queMessage = (Message)iter.next(); //you will be invoking .next() only once

     if(queMessage.data[2].equalsIgnoreCase(ackMessage.data[6]))
     {
          (Integer.parseInt(queMessage.data[6])+1);

     }
}

Instead of directly using (Message)iter.next() in your if conditions, try this.

Message queMessage = (Message)iter.next();

Full code

 while(iter.hasNext())
{

    Message queMessage = (Message)iter.next(); //you will be invoking .next() only once

     if(queMessage.data[2].equalsIgnoreCase(ackMessage.data[6]))
     {
          (Integer.parseInt(queMessage.data[6])+1);

     }
}

回复收藏 0 原文