监控队列- ConcurrentLinkedQueue？
监控队列（ConcurrentLinkedQueue）是一种线程安全的无界非阻塞队列，它是Java并发包（java.util.concurrent）中的一部分。它实现了Queue接口，并提供了高效的并发操作。
概念：
监控队列是一种基于链表结构的队列，它使用CAS（Compare and Swap）操作来实现线程安全。它不需要使用锁来保护共享资源，因此在高并发环境下具有较好的性能。
分类：
监控队列属于非阻塞队列的一种，与阻塞队列相比，它不会在队列满或空时阻塞线程，而是通过自旋和CAS操作来实现并发访问。
优势：
- 高并发性能：监控队列使用无锁算法，避免了锁竞争，能够支持高并发的读写操作。
- 无界队列：监控队列没有固定的容量限制，可以根据需求动态地添加元素。
- 线程安全：监控队列通过CAS操作来保证线程安全，避免了使用锁带来的性能开销和线程阻塞。
应用场景：
监控队列适用于需要高并发读写的场景，特别是在生产者-消费者模型中，多个线程可以并发地向队列中添加元素或者获取元素。例如，消息队列、任务调度等场景都可以使用监控队列来实现。
推荐的腾讯云相关产品：
腾讯云提供了一系列与云计算相关的产品和服务，以下是一些推荐的产品：
- 云服务器（CVM）：提供弹性计算能力，可根据需求快速创建、部署和扩展虚拟机实例。
- 云数据库MySQL版（CDB）：提供高可用、可扩展的关系型数据库服务，适用于各种应用场景。
- 云监控（Cloud Monitor）：提供全面的云资源监控和告警服务，帮助用户实时了解资源的运行状态。
- 云存储（COS）：提供安全可靠的对象存储服务，适用于存储和处理各种类型的数据。
- 人工智能平台（AI Lab）：提供丰富的人工智能算法和模型，帮助用户快速构建和部署AI应用。
更多腾讯云产品和详细介绍，请访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
我在生产者-消费者场景中使用ConcurrentLinkedQueue。我的生产者是我的应用程序中所有方法调用的Singleton : Producer.getInstance().add("foo")；add()方法调用ConcurrentLinkedQueue ConcurrentLinkedQueue方法。
public void add(String message) {
myQueue.offer(message);
}
否则，我让我的使用者在另一个线程中运行，只需在生产者内部的ConcurrentLinkedQueue上调用轮询方法。
编辑：
在if ((缓
浏览 2提问于2012-07-10得票数 0
是否可以将名为ConcurrentLinkedQueue的非阻塞队列传递给ThreadPoolExecutor而不是LinkedBlockingQueue(或任何其他阻塞队列)？
浏览 2提问于2015-01-07得票数 0
我有以下关于Java7 ConcurrentLinkedQueue的问题。让我们假设我有以下课程：
public class Blah {
private ConcurrentLinkedQueue<String> queue;
public Blah() {
queue = new ConcurrentLinkedQueue<String>();
}
public void produce(String action, String task) throws InterruptedException {
浏览 2提问于2015-04-12得票数 0
回答已采纳
1回答
这里有点“菜鸟”的问题。
我有一个小的应用程序要写(就像一个简单的游戏)。有服务器端和客户端。它必须使用websockets作为通信方式。Server有一个服务器类(带有启动服务器的main() )和服务器端点类。然而，这个游戏不是基于回合的，而是基于实时的。因此，服务器必须对动态字段的每个“滴答”b/c进行某些计算。我假设线程在这种情况下很适合，但我不知道如何将线程放入这种服务器中。
正如我所看到的，唯一可以接收/发送消息的是端点。如果我让它实现Runnable并每隔0.5秒暂停一次，那么在暂停时间内它不会接受消息。如果我为此定义了一个不同的类，我不知道如何在端点中启动它，并为它们提供一种通
浏览 3提问于2015-05-09得票数 0
我使用spring-csv读取csv文件，如下面的示例所示 examples 对于这个目标，我创建了这个方法 public static <T> List<T> loadObjectList(Class<T> type, File file) {
try {
CsvSchema bootstrapSchema = CsvSchema.emptySchema().withHeader().withColumnSeparator('$');
CsvMapper mapper =
浏览 11提问于2019-12-11得票数 0
在我的应用程序中，数据生成速度(存储在concurrentLinkedQueue中)比使用单线程的速度要大。
我决定从创建4个线程开始使用数据，以防止我的应用程序“内存不足异常”。
问题：
对于上述问题，还有其他更好的设计吗？
我们可以使用多个线程在concurrentLinkedQueue上迭代并在迭代时删除元素吗？
内存一致性效应:与其他并发集合一样，在将对象放入ConcurrentLinkedQueue之前，线程中的操作会在访问或从另一个线程中的ConcurrentLinkedQueue中删除该元素之后发生。
浏览 3提问于2017-07-24得票数 2
回答已采纳
1回答
目前，我正在使用LinkedList添加所有Command信息。如何使下面的List<Command>线程安全？我是否应该在这里使用其他选项而不是LinkedList？
private static List<Command> commands;
Command command = new Command();
command.setName(commandName);
command.setExecutionPercentage(Double.parseDouble(percentage));
command.setAttributeIDGet(attributeI
浏览 1提问于2012-08-20得票数 1
回答已采纳
我想知道AtomicReferenceArray是否可以用作ConcurrentLinkedQueue的替代品(如果可以使用有界结构)。
我目前有一些类似的东西：
ConcurrentLinkedQueue<Object[]> queue = new ConcurrentLinkedQueue<Object[]>();
public void store(Price price, Instrument instrument, Object[] formats){
Object[] elements = {price, instrument, formats}
浏览 1提问于2012-02-04得票数 2
回答已采纳
如果多个线程试图访问从LinkedList而不是ConcurrentLinkedQueue实现的队列，会发生什么情况
假设每个线程只使用add()和poll()，没有其他函数调用，这两个操作是原子的吗？
如果它们是原子的，那么使用ConcurrentLinkedQueue而不是常规的LinkedList实现有什么好处吗？
浏览 0提问于2015-11-26得票数 1
我的Server类中有一个Queue：
public class Server{
Queue<Input> inputQueue;
public void start() {
inThread = new InThread(inputQueue);
outThread = new OutThread(inputQueue);
inThread.start();
outThread.start();
}
}
inThread将负责在inputQueue中填充数据，outThread将负责从outputQu
浏览 1提问于2013-08-15得票数 1
当前正在队列的头的for循环中处理的元素吗？
private Queue<User> users = new ConcurrentLinkedQueue<User>();
for(User u : users){
users.remove(); // <- is this removing the currently iterated element?
}
还是在这里使用users.remove(u)更好？
浏览 2提问于2015-06-21得票数 1
回答已采纳
2回答
我有一个要求，我将点击一个链接，并得到回应。响应是包含子链接的XML数据。然后将响应复制到文件中，并将子链接添加到队列中，在队列中，我必须迭代地访问子链接，直到没有更多的子链接。
我首先使用一个队列来完成这个任务。但由于速度慢，我试着实现一个执行者。我不需要维护数据的顺序。这就是我现在的做法：
public class Hierarchy2 {
private static AbstractQueue<String> queue = new ConcurrentLinkedQueue<>();
private static FileWriter wr
浏览 4提问于2017-09-19得票数 0
回答已采纳
我不知道如何做到这一点，我想迭代ConcurrentLinkedQueue (所有这些)，删除第一项并在其上执行一些代码。
这是我习惯做的事：
public static class Input {
public static final ConcurrentLinkedQueue<TreeNode> treeNodes = new ConcurrentLinkedQueue<>();
}
public static class Current {
public static final ConcurrentHashMap<Integer,
浏览 4提问于2016-07-08得票数 1
回答已采纳
1回答
Buffer类具有write和read方法。缓冲区由多个线程使用。生成数据的线程使用write方法向缓冲区写入数据值；使用数据的线程调用read方法从缓冲区获取下一个数据值。下面的代码在只有一个线程时工作，但是当使用多个线程时，read和write方法是不正确的。
描述纠正这两个方法的代码所需的4个更改，解释每个更改的效果。(如果愿意，您可以写出更正的代码，但这不是必需的。)
public class Buffer<E> {
private int maxSize ; // the maximum length of the buffer
private List
浏览 1提问于2015-05-13得票数 1
我有一个ArrayList，它将被缓存并无限期地在多个线程之间共享。操作包括频繁的添加和删除，以及偶尔对其进行迭代。
ArrayList驻留在一个包装类中，该类管理对它的访问：
public class MyListWrapper<T> implements Iterable<T> {
private List<T> innerList = new ArrayList<T>();
public Iterator<T> iterator() {
return innerList.listIterato
浏览 1提问于2011-05-20得票数 14
回答已采纳
我有一个工作线程，它应该在ArrayList<ConcurrentLinkedQueue>上迭代。其他线程可以添加和删除对象(队列)。但是ArrayList并不是线程安全的。用ConcurrentLinkedQueue<ConcurrentLinkedQueue>代替ArrayList<ConcurrentLinkedQueue>好吗？
浏览 2提问于2016-04-13得票数 0
回答已采纳
1回答
我有以下代码：
public void searchStringInFile(String directory, String word)
{
if (word != null && directory != null)
{
File filePath = new File(directory);
Queue<File> queue = new LinkedList<>();
queue.add(filePath);
浏览 0提问于2018-10-10得票数 2
回答已采纳
我有ConcurrentLinkedQueue和队列更新在主线程和AsyncTask显示在ConcurrentLinkedQueue内的数据。它在第一次发射时运行正常。
如果应用程序被后退键或主键停止，那么应用程序将重新启动，问题就在那里。在主线程中，队列有数据，但在AsyncTask中，队列长度为零。
然而，该应用程序是强制停止和重新启动，然后它是好的。
这个Queue有什么问题？
我用碎片。
public class OneFragment extends Fragment implements SensorEventListener {
Queue<Float> q
浏览 3提问于2016-03-11得票数 0
回答已采纳
我知道这种数据结构对于队列和脱队列具有恒定的时间性能，但是对于删除(对象o)，它有恒定的时间性能吗？
浏览 1提问于2013-12-25得票数 1
我有一些代码，允许服务器生成一些地形，然后通过数据报数据包将这些数据发送到一个单独的客户端程序。接收此数据的客户端的伪代码如下：
-client sends SYN message to server
-server responds with ACK message (using 2-step SYNACK)
-client sends request for terrain from x=0 to x=32
-server responds with 32 seperate packets, one for each x (to keep packet size small)
-clien
浏览 0提问于2016-05-08得票数 0
回答已采纳
我使用combineLatest连接两种类型的任务的两种流。处理两种类型的任务应该相互交织。是否可以确定哪个流发出对的最后值？我使用带有时间戳的解决方案，但这是不正确的。每个主题都包含默认值。
List<Flowable<? extends Timed<? extends Task>>> sources = new ArrayList<>();
Flowable<Timed<TaskModification>> modificationSource = mTaskModificationSubject
.on
浏览 0提问于2018-05-06得票数 1
回答已采纳
3回答
如果一个队列要由多个线程访问，但它目前只被一个方法getNextInQueue()修改，那么同步对队列的访问最合适的形式是什么？
目前，我将队列声明为ConcurrentLinkedQueue，但我不希望出现多个线程正在等待一个锁被释放的死锁。我可以处理的另一种方法是不同步队列，而是同步getNextInQueue()。然而，随着这段代码在未来的使用，我认为这不会有那么大的伸缩性。(对队列进行修改的每个程序员都必须确保同步操作。)
有什么想法？
浏览 1提问于2012-07-11得票数 4
回答已采纳
我的代码：
while( Memo.qRcv.size() > 0) {
MessageReceived msg=Memo.qRcv.poll();
...
}
然后我得到了
2014-03-01 11:09:36 DEBUG [Thread-16] (threadQueueSendtoUser.java:163) - Memo.qRcv = null, size = 41590
浏览 2提问于2014-03-01得票数 5
回答已采纳
我在使用ConcurrentLinkedQueue时出现了以下错误
错误:从lambda表达式中引用的局部变量必须是最终的或实际上是最终的。
我有非常简单的代码，我只想从多个线程向队列添加值。问题是，类似的代码可以很好地处理类似类型的查询。
import java.util.concurrent.ConcurrentLinkedQueue;
ConcurrentLinkedQueue<Double> concurrentLinkedQueue = new ConcurrentLinkedQueue<Double>();
threads = new Array
浏览 1提问于2015-12-23得票数 1
回答已采纳
我的类中有一个ConcurrentLinkedQueue字段，在中运行一个简单的单线程测试时，我的行为非常不稳定。
我的班级：
public class ArchiverData
{
/** The pricing API records */
private ConcurrentLinkedQueue<ArchiverApiResponseDTO> pricingQueue =
new ConcurrentLinkedQueue<ArchiverApiResponseDTO>();
[...]
public int getApiResponseCoun
浏览 1提问于2017-06-22得票数 0
回答已采纳
我知道，对于这样的生产者/消费者对，应该使用阻塞队列。我想要的只是理解Java中更好的内存一致性，并发数据结构和锁之间的交互，以及在确定ConcurrentLinkedQueue大小时的不精确性。
问题是，下面的算法是否保证，产生的任何东西都会被消耗，就像在一个普通的非线程安全队列的情况下一样？注:我运行了几次，一直都是这样的。
import java.util.concurrent.ConcurrentLinkedQueue;
public class Produce extends Thread {
@Override
public void run() {
浏览 3提问于2021-02-12得票数 1
回答已采纳
我有以下设计：
有一个扩展TimerTask的任务，它计划每分钟运行一次。此任务将尝试从中央队列(作为单个使用者)获取项，并将其表示写入文件中。
此外，还有多个生产者不时地将项目放入中央队列。
我感兴趣的是，每次执行任务(run() method executed)时，如果有项，如果没有项，它将从队列中提取所有。
如果队列满了，生产者应该在队列上睡觉。
我对这个问题的解决办法是：
创建扩展ExtractTask的TimerTask。ExtractTask将包含一个BlockingQueue。每个生产者将通过执行方法getQueue()来接收对队列实例的引用。生产者将执行BlockingQueu
浏览 7提问于2012-10-22得票数 0
回答已采纳
在我的程序中有两个类A和B，它们都扩展了线程，现在B有一个名为CommandQueue的队列。现在线程B访问它，直到它变为空，A类线程在发现要插入到它中的新命令时访问它。如何使此队列同步，以便两个线程都不能访问它，并且当一个线程使用此队列时，使其可供另一个线程使用。另外，如果我没有使它同步，也请建议如果没有任何问题。
浏览 0提问于2011-09-21得票数 1
回答已采纳
假设线程A试图向ConcurrentLinkedQueue添加一个元素，同时线程B试图向同一ConcurrentLinkedQueue添加一个不同的元素。
这两个项目是否会被添加到队列中，或者我是否会遇到并发问题(比方说，可能只插入一个)？
我知道这个队列是线程安全的，但是我不知道这是否意味着当我在同一时间从不同的线程调用它两次时，我可以假设这个方法也是安全的。
如果不是这样，也许方法put/offer对于这种情况是安全的？
浏览 0提问于2015-12-29得票数 0
1回答
Java串行通信与多线程
、、、
我正在读取从Arduino到我构建的Java程序的数据。我想对数据做的是图形和存储它(可能在一个CSV)在同一时间。图形化和存储不应该太难。我担心的是，这样做的速度足够快，不会丢失任何输入的数据。因此，我在这里的问题主要是设计问题。
我当前的思考过程:我在main()中有一个事件侦听器，它接收所有传入的串行数据并将其放入队列中。我有一个线程(让我们称之为线程A)在另一端等待数据。在将数据保存到文件之前，该线程将立即将数据发送到另一个线程(B)。线程B担心绘制数据。
但是我很好奇，当线程A从队列中提取数据时，所有试图从事件侦听器进入的数据会发生什么呢？我应该有另一个队列，以防第一个队列忙着来回交
浏览 2提问于2015-03-14得票数 1
回答已采纳
目前在多线程环境中，我们使用LinkedList来保存数据。有时，在日志中，当它轮询链表时，我们会得到NoSuchElementException。如果我们从链表转移到ConcurrentLinkedQueue实现，请帮助理解性能影响。
谢谢，Sachin
浏览 0提问于2011-09-06得票数 7
回答已采纳
下面是主要的活动代码，我通过广播从服务处获得文本，我想使用wifi将该文本转发到服务器。
我在想，我可以把这个应用程序注册为客户端，然后将文本发送到另一个安装服务器应用程序的手机上。但我不知道该怎么做。它应该是自动完成的，不需要按任何按钮。
有什么主意吗？？
这段代码是由不同的例子组合而成的，如果它看起来很粗糙，但至少它能工作，那么很抱歉；)
我分隔了为TCP客户端添加的行：
//用于套接字客户端启动
//用于套接字客户端
谢谢!
码
import android.app.Activity;
import android.bluetooth.BluetoothDevice;
import an
浏览 1提问于2015-07-01得票数 0
回答已采纳
我有一个下面的类，其中多个线程将调用add方法，以线程安全的方式填充channelMessageHolder CHM。
在同一个类中，我有一个后台线程，它每30秒运行一次，它通过从send传递数据来调用channelMessageHolder.方法。
public class Processor {
private final ScheduledExecutorService executorService = Executors
.newSingleThreadScheduledExecutor();
private final AtomicReference<Co
浏览 4提问于2017-02-04得票数 2
回答已采纳
2回答
我想实现我自己的记录器，在文件中写入日志。它可以从多个线程运行，问题是如何同步对日志文件的访问。
private synchronized static void writeToFile(String tag, String msg,
Throwable tr, Context ctx) {
try {
String s = System.getProperty("line.separator");
File f = Environment.getExternalStorageDirectory();
浏览 2提问于2012-11-26得票数 1
当我有ConcurrentLinkedQueue时，我为什么要使用LinkedBlockingQueue？我知道ConcurrentLinkedQueue是非阻塞的，但是LinkedBlockingQueue可以作为ConcurrentLinkedQueue工作。我将使用put()/offer()方法进行插入，而poll()方法用于删除。如果队列为空，则poll()方法不会等待。LinkedBlockingQueue也是无限的。所以我可以用这个。
到目前为止，我发现的不同之处在于，ConcurrentLinkedQueue使用的是带有比较和交换的硬件级同步机制，而LinkedBlockingQ
浏览 3提问于2018-04-15得票数 10
3回答
我需要某种队列来同步添加新元素和删除新元素：
同步应该在添加元素、删除元素以及添加/删除方法之间进行。
我想到了一些选择：
要找到线程安全的队列实现，这意味着无论哪种方法调用，对队列的访问都会阻止它
2.在某些锁对象上使用synchronize对add/remove元素方法进行包装。->这个解决方案看起来有点难看。
你对此有何看法？
浏览 3提问于2014-02-28得票数 0
回答已采纳
当我执行下面的代码时，我得到了ConcurrentModificationException
Collection<String> myCollection = Collections.synchronizedList(new ArrayList<String>(10));
myCollection.add("123");
myCollection.add("456");
myCollection.add("789");
for (Iterator it = myCollection.it
浏览 2提问于2011-07-06得票数 8
回答已采纳
我正试图通过ScheduledExecutorService在安卓系统中实现生产者-消费者模式。因此，我创建了一个生产者工作线程和一个消费者线程，前者从网站加载数据，后者过滤这些数据。以下是用于演示我的问题的代码片段：
public void RunPeriodicBackgroundTasks() {
private final ScheduledExecutorService backgroundTaskExecutor_ = Executors.newScheduledThreadPool(2);
backgroundTaskExecutor_.scheduleAtFixedRate
浏览 1提问于2013-02-21得票数 1
回答已采纳
ConcurrentLinkedDeque和ConcurrentLinkedQueue：的Api链接
这两者有什么区别呢？
第一种，DeQueue有更多的方法，但两者之间的基本区别是什么？
浏览 5提问于2015-01-30得票数 12
回答已采纳
我的问题与之前提出的有关。在我使用队列在生产者线程和消费者线程之间进行通信的情况下，人们通常会推荐使用LinkedBlockingQueue或ConcurrentLinkedQueue
使用一种比另一种有什么优点/缺点？
从API的角度来看，我能看到的主要区别是，LinkedBlockingQueue可以是可选的绑定。
浏览 2提问于2009-09-15得票数 120
回答已采纳
我对爪哇和泽西都很陌生。现在，我想使用这个jersey来实现在发送响应后具有额外处理的REST服务(具体来说，在同一个servlet上下文中睡眠固定的秒，然后触发一个不同的REST请求，所以它与REST代理不同)。我在googled上搜索了一段时间，但所有的人似乎都想当然地认为，在方法的末尾隐式地刷新响应是理所当然的。下面是启用JAXB的当前代码，我正在努力工作。
@Path("/chat")
public class LoadSimulator {
@Context private UriInfo uriInfo;
@Path("/outbound
浏览 1提问于2011-11-06得票数 0
1回答
我想实现一个监控队列，两个不相关的线程可以共享这个队列。在这种情况下，只使用ConcurrentLinkedQueue就足够了吗?或者我应该以不同的方式使用它？我想实现活动对象设计模式，有一个ActivationQueue --它是一个普通的Java队列，它必须作为一个监视器对象来实现，因为除了队列之外，还有其他的模式组件。
浏览 11提问于2017-01-12得票数 2
回答已采纳
我看过博客，但我不确定他的结论是否正确：
他说:正如您从所提供的性能结果中可以看到的那样，实现了最佳组合(添加和删除元素)性能结果，并且应该是您实现生产者-消费者计划的头号候选人。
我想知道，如果我没有在我的代码中使用锁，那不是更快吗？
那么，为什么LinkedBlockingQueue比无锁队列(ConcurrentLinkedQueue)更快呢？
谢谢！
浏览 0提问于2012-09-05得票数 5
回答已采纳
1回答
我正在试着为我的排队问题找到一个解决方案。在典型的场景中，生产者将一些东西放在队列中，而消费者将其取下。如果我们有一个生产者和一个消费者，前者也消费，后者最初从队列中取出一些东西，然后把一些东西(比如结果)放回队列中。因此，如果你遵循，就会有一个双向的流动。有没有可能同步两个线程来有效地做到这一点？天真的是，我在我的一个线程的run方法中放了一个循环，结果发现另一个线程只运行一次，然后就死了。如果出现这种情况，很抱歉，vague..Hopefully有人可以给我指路
干杯
浏览 0提问于2012-10-30得票数 0
回答已采纳
我需要迭代一个同时在其他地方被修改的列表，我读到这个列表在ArrayList中是不可能的。
有人知道我能用什么吗？或者这是可能的？我认为这样做是为了满足我的需要，但如果没有其他选择，我会研究这个问题。无论如何，希望能得到另一个建议:)
代码
Iterator<blabla> haha = bytes.iterator();
while(haha.hasNext()) {
blabla aStorage = haha.next();
TimeUnit.MILLISECONDS.sleep(120);
}
和其他地方
bytes.add(aStorage);
浏览 5提问于2017-06-03得票数 0
回答已采纳
2回答
不同步的Java等待/通知实现
、、、、
我有一个有几十个制片人和一个消费者的场景。时间是至关重要的:出于性能原因，我希望避免生产者的任何锁定，并且当没有消息准备好时，我希望使用者尽可能少地等待。
我已经开始使用ConcurrentLinkedQueue了，但是我不喜欢在sleep上调用queue.poll() == null，因为这会浪费宝贵的毫秒时间，而且我不想使用yield，因为我最终会浪费cpu。
因此，我来实现一种ConcurrentBlockingQueue，这样消费者就可以运行以下内容：
T item = queue.poll();
if(item == null) {
wait();
item = qu
浏览 2提问于2018-02-15得票数 3
2回答
节律任务控制器
、、
有节奏任务控制器的目的是接受一个任务，并在客户端代码定义的循环或“节律”中执行所有排队的任务。任务返回true或false，取决于它是否“完成”。完成的任务应该从控制器的控件中移除，并且不会再次执行，而未完成的任务应该在下一个周期中执行。
我不认为我的解决方案是尽可能优化的，这是一个解决方案，需要尽可能快，因为它作为核心任务控制器在我的游戏框架！
import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor;
import java.util.concurrent.ConcurrentHashMap
浏览 0提问于2015-04-05得票数 2
回答已采纳
作为我项目的一部分，我需要创建一个包含固定数量的threads.when的线程池只要线程被分配给不同的进程，我就需要分配那么多的会话和线程。我想使用一个固定大小的ConcurrentLinkedQueue来存储会话，以便在线程完成时，我可以将我的会话放回队列中，使其可供其他processes.Hope使用。我的要求是clear...Can任何人给我一些关于如何实现这一点的查询语句。。？如何使用ConcurrentLinkedQueue？
浏览 1提问于2011-02-28得票数 0
背景
我有一个程序，通过使用Java代理和ASM，它添加了一个包含ConcurrentLinkedQueues of Object数组的静态Object(在下面的代码段中称为ThreadMarkers )。映射的键是线程in，它的值是ThreadMarker的队列。每个队列被添加到给定的.class文件中遇到的每一个新的.class字节码指令，在给定的.class文件中，遇到该行的线程使用它的id属性来标识要添加到映射中的队列。
Code (注意，QueueMapMediator的映射队列不必是ConcurrentLinkedQueues --它们每个只由一个线程访问)。
public cla
浏览 4提问于2022-08-20得票数 1
1回答
客户端/服务器应用程序。多个客户端可以连接到服务器。对于每个客户端连接，服务器都会创建新线程。客户端发送数据，直到它关闭套接字。因此，我需要每次都将由线程服务器管理的数据返回到主服务器。我不能等待线程完成它的工作，因为我不知道客户端何时关闭连接。正确的方法是什么？
浏览 1提问于2015-07-03得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
