事件队列如何实现去中心

『壹』 消息队列中的事件如何触发

一个事件产生一个消息，消息进入自己的消息队列，再把消息派发到各个自己的消息响应函数里去实现事件的响应

『贰』 下面是一个用js来实现的获取队列信息的方法，我要怎么把它改成java代码，来取得队列中的值。

这个 是websocket， JAVA 中要使用第3方库，，，，如 TooTallNate-Java-WebSocket

~~~~~~~

『叁』 事件队列和消息队列之间的区别

事件是一个动作——用户触发的动作。
消息是一个信息——传递给系统的信息。

事件与消息的概念在计算机中较易混淆，但本质不同：

事件由用户（操作电脑的人）触发且只能由用户触发，操作系统能够感觉到由用户触发的事件，并将此事件转换为一个（特定的）消息发送到程序的消息队列中。

这里强调的是：
可以说“用户触发了一个事件”，而不能说“用户触发了一个消息”。
用户只能触发事件，而事件只能由用户触发。
一个事件产生后，将被操作系统转换为一个消息，所以一个消息可能是由一个事件转换而来（或者由操作系统产生）。
一个消息可能会产生另一个消息，但一个消息决不能产生一个事件——时间只能由用户触发。

总结（事件：消息的来源）
事件：只能由用户通过外设的输入产生。
消息：（产生消息的来源有三个）
（1） 由操作系统产生。
（2） 由用户触发的事件转换而来。
（3） 由另一个消息产生。

『肆』 到底什么是消息队列Java中如何实现消息队列

“消息队列”是在消息的传输过程中保存消息的容器。和我们学过的LinkedHashMap，TreeSet等一样，都是容器。既然是容器，就有有自己的特性，就像LinkedHashMap是以键值对存储。存取顺序不变。而消息队列，看到队列就可以知道。这个容器里面的消息是站好队的，一般遵从先进先出原则。

java中已经为我们封装好了很多的消息队列。在java 1.5版本时推出的java.util.concurrent中有很多现成的队列供我们使用。特性繁多，种类齐全。是你居家旅游开发必备QAQ。

下面简单列举这个包中的消息队列

1. :阻塞队列 BlockingQueue

2. 数组阻塞队列 ArrayBlockingQueue

3. 延迟队列 DelayQueue

4. 链阻塞队列 LinkedBlockingQueue

5. 具有优先级的阻塞队列 PriorityBlockingQueue

6. 同步队列 SynchronousQueue

7. 阻塞双端队列 BlockingDeque

8. 链阻塞双端队列 LinkedBlockingDeque

   不同的队列不同的特性决定了队列使用的时机，感兴趣的话你可以详细了解。具体的使用方式我就不赘述了

『伍』 java中如何实现按队列执行任务

package com.tone.example;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import com.tone.task.TaskProperty;
import com.tone.task.TaskSignature;
import com.tone.task.impl.BasicTask;
import com.tone.task.runner.TaskRunner;

/**
* 任务队列示例程序
* @author zlf
*/
public class TaskExample {
private TaskRunner taskRunner;

/**
* 做任务队列的初始化工作
*/
@Before
public void init() {
// 获取任务运行器
taskRunner = TaskRunner.getInstance();
// 将任务运行器放入线程进行调度
Thread thread = new Thread(taskRunner);
thread.start();
}

/**
* 等待任务执行完成，并做最后的退出工作
*/
@After
public void exit() throws InterruptedException {
Thread.sleep(600);
System.exit(0);
}

/**
* 最简单的任务运行示例
*/
@Test
public void example1() {
// 添加任务到任务运行器
taskRunner.addTask(new BasicTask() {
@Override
public void run() {
System.out.println("This is running in task runner thread, and thread is " + Thread.currentThread());
}
});
}

/**
* 加入优先执行顺序的任务运行器
*/
@Test
public void example2() {
// 添加任务到任务运行器
taskRunner.addTask(new BasicTask(0) {
@Override
public void run() {
System.out.println("This is a normal task");
}
});
taskRunner.addTask(new BasicTask(-1) {
@Override
public void run() {
System.out.println("This is a task a bit high than normal");
}
});
}

/**
* 重复添加的任务只会运行第一个
*/
@Test
public void example3() {
// 添加任务到任务运行器
taskRunner.addTask(new BasicTask(TaskSignature.ONE) {
@Override
public void run() {
System.out.println("This is task one");
}
}, TaskProperty.NOT_REPEAT);
taskRunner.addTask(new BasicTask(TaskSignature.ONE) {
@Override
public void run() {
System.out.println("This is also task one");
}
}, TaskProperty.NOT_REPEAT);
}

/**
* 重复添加的任务只会运行最后一个
*/
@Test
public void example4() {
// 添加任务到任务运行器
taskRunner.addTask(new BasicTask(TaskSignature.ONE) {
@Override
public void run() {
System.out.println("This is task one");
}
}, TaskProperty.NOT_REPEAT_OVERRIDE);
taskRunner.addTask(new BasicTask(TaskSignature.ONE) {
@Override
public void run() {
System.out.println("This is also task one");
}
}, TaskProperty.NOT_REPEAT_OVERRIDE);
}
}

『陆』 如何实现自动监听消息队列里的值

通过使用微软的 消息队列（MSMQ）,然后在控制台应用程序里加一个线程监听，这样只要发现有值就可以执行应该执行的程序。

『柒』 消息队列怎么实现消息传送

一般来说，这个程序是不可以用的！

『捌』 C#如何取消事件队列，就是一个事件未执行完时再次触发事件，后面的事件不进入队列

想取消是不可能的了，这是 CLR 自己处理的而不是你写的。

但可以换种思路，题主的要求不就是同一个事件之间要互斥吗？可以设置一个 flag。事件进入方法后先判断该 flag 是否为 false，如果是则改为 true 并继续执行，否则跳出该方法。过程执行结束后再改回 false。

『玖』 队列有哪些操作，分别说明这些操作实现的步骤与方法

以下是两个线程：

import java.util.*;

public class Thread_List_Operation {
//假设有这么一个队列
static List list = new LinkedList();

public static void main(String[] args) {
Thread t;
t = new Thread(new T1());
t.start();
t = new Thread(new T2());
t.start();

}

}

//线程T1,用来给list添加新元素
class T1 implements Runnable{

void getElemt(Object o){
Thread_List_Operation.list.add(o);
System.out.println(Thread.currentThread().getName() + "为队列添加了一个元素");
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
getElemt(new Integer(1));
}

}

}

//线程T2,用来给list添加新元素
class T2 implements Runnable{

void getElemt(Object o){
Thread_List_Operation.list.add(o);
System.out.println(Thread.currentThread().getName() + "为队列添加了一个元素");
}
@Override
public void run() {
for (int i = 0; i < 10; i++) {
getElemt(new Integer(1));
}

}

}

//结果（乱序）
Thread-0为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-0为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-1为队列添加了一个元素
Thread-0为队列添加了一个元素
Thread-0为队列添加了一个元素
Thread-0为队列添加了一个元素
Thread-0为队列添加了一个元素
Thread-0为队列添加了一个元素
Thread-0为队列添加了一个元素
Thread-0为队列添加了一个元素
Thread-0为队列添加了一个元素

『拾』 事件队列是什么_

举个简单的例子去食堂吃饭需要排队，假如食堂使我们的程序，那么排队打饭的就是一个事件队列。