并发编程

今天我们模拟写一个简单的聊天应用程序，首先我们需要定义聊天程序的几个Event User Online Event:当用户:上线时来到聊天室的Event。 User Offline Event:当用户下线时退出聊天室的Event。 User...

赞(0)黑客云2020-06-12阅读(413)去评论

1. 事件驱动模式介绍 事件驱动设计模式是一种实现组件松耦合，易拓展的架构方式。一个简单的事件驱动设计需要包括三大组件。 Events：需要被处理的数据 Event Handlers:处理数据的方式方法 Event Loop ：维护Even...

赞(0)黑客云2020-06-10阅读(513)去评论

JDK自1.7版本后提供了WatchService类，该类可以基于事件通知的方式监控文件或者目录的任何变化，文件的改变相当于每个事件( Event)的发生，针对不同的时间执行不同的动作，结合NIO2.0中提供的WatchService 和我...

赞(0)黑客云2020-06-09阅读(389)去评论

相信每一位读者都有使用过消息中间件的经历，比如Apache ActiveMQ和ApacheKafka等，某subscriber在消息中间件上注册了某个topic (主题)，当有消息发送到了该topic.上之后，注册在该topic.上的所有s...

赞(0)黑客云2020-06-08阅读(334)去评论

标准的ActiveObjects要将每一个方法都封装成Message(比如多线程设计模式之:Actvice Object设计模式定义的FindOrderDetailsMessage, OrderMessage), 然后提交至Message队...

赞(0)黑客云2020-06-07阅读(302)去评论

1. 主动对象模式 ActiveObjects主动对象模式的意思拥有独立的线程，还可以接收异步消息。并且能够返回处理结果。 在java虚拟机中，我们显示调用system.gc(),它就是一个接收异步消息的主动对象。调用GC方法的线程和gc自...

赞(0)黑客云2020-06-06阅读(321)去评论

Thread Per Message的意思是为每一个消息的处理开辟一个线程使得消息能够以并发的方式进行处理，从而提高系统整体的吞吐能力。这就好比电话接线员一样，收到的每一个电话投诉或者业务的处理请求，都会提交对应的工单，然后交由对应的工作人员来处理。

赞(0)黑客云2020-06-05阅读(338)去评论

1. 什么是Latch设计模式 比如若干线程并发执行某个特定的任务，然后等到所有的子任务都执行结束之后再统一汇总，比如用户想要查询自己三年以来银行账号的流水，为了保证运行数据库的数据量在-一个恒定的范围之内，通常数据只会保存一年的记录，其他...

赞(0)黑客云2020-06-01阅读(358)去评论

假设有个任务需要执行比较长的时间，通常需要等待任务执行结束或者出错了返回结果，在此期间调用者只能阻塞等待返回，因此Futrue设计模式提供了一种凭据式的解决方案。 自JDK1.5起，Java提供了比较强大的Future接口,在JDK1.8时...

赞(0)黑客云2020-05-31阅读(335)去评论

1.场景描述 在多线程的情况下访问共享资源，需要对资源进行同步操作防止数据不一致的情况，通常我们使用synchronized关键字或者显示锁。 对资源的访问一般包括两种类型的动作-读和写，如果多个线程在某个时刻都在进行资源的读操作，如果这个...

赞(0)黑客云2020-05-30阅读(383)去评论