Cómo utilizar JAVA para implementar el procesamiento de información asíncrono

Por lo general, la sincronización significa que un determinado proceso de procesamiento de una tarea será procesado en serie por varios subprocesos, mientras que la asincrónica significa que un determinado proceso de procesamiento puede permitir que varios subprocesos se procesen al mismo tiempo. Asíncrono generalmente representa un mejor rendimiento, porque depende en gran medida del almacenamiento en búfer, que es una práctica típica de usar espacio por tiempo. Por ejemplo, en las computadoras, el caché actúa como una zona de búfer entre la CPU y el disco IO para coordinar la alta velocidad de la CPU. cálculos y las capacidades de lectura y escritura de baja velocidad del disco.

(1): Reiniciar un programa java inicia un proceso

Puedes usar la línea de comando del sistema operativo para iniciar Runtime.getRuntime().exec("java -classpath . XXX" );

(2): ¿Puede agregar una función de procesamiento especial a la función addtolist en el módulo que recibe el mensaje? Cuando se ejecuta la función, primero agregue el mensaje a la lista y luego detecte si. Actualmente hay un hilo de procesamiento. Si no, inicie el hilo.

(3): Si desea ahorrar algo de trabajo, puede usar BlockingQueue en lugar de la lista, de modo que los subprocesos que esperan y se activan no necesitan escribir código. Si debe usar la lista, sincronícela.

Pequeño ejemplo de lista:

Código Java MessageConsumer extends Thead { lista privada lista; ejecución booleana privada = true; public MessageConsumer(List lista) {this. lista = lista;} public void run() { while (ejecutando) { YourMessageType msg = null; intentar { sincronizado(lista) { while (list.size() == 0) { list.wait() } msg = lista; .remove(0) ; list.notiryAll(); } } catch (Excepción e) { e.printStackTrace(); if (msg == null) continuar //System.out.println(msg); mensaje } }}/ /Llame a sampleclass ShareModule { List list = new ArrayList(); ...} public class Main { public static void main(String[] args) { ShareMudule sm; ... Hilo t = nuevo MessageConsumer(sm.list); t.start()... }}