草庐IT

notify-keyspace-events

全部标签

java - Java 事件,特别是 javax.enterprise.event.fire() 的行为如何?

我有以下情况(在JBossAS6和AS7上运行):具有预定方法的单例EJB。SomethingChangedEvent类型的注入(inject)事件考虑以下示例:@SingletonpublicfinalclassScheduler{@InjectprivateEventevent;@ScheduleprivatevoidscheduleSomething(){event.fire(newSomethingChangedEvent());}}我希望这个事件被添加到服务器上的某种队列中并由它分发。任何使用@Observers观察此类事件的方法都会收到通知。event.fire()方法将立

Java 网络 : evented Socket/InputStream

我正在Java的套接字上实现一个面向事件的层,我想知道是否有一种方法可以确定是否有待读取的数据。我通常的方法是从套接字读取到缓冲区,并在缓冲区填充给定字节数时调用提供的回调(如果每次到达时都需要触发回调,则可以为0),但我怀疑Java已经在为我做缓冲。InputStream的available()方法是否可靠?我应该只read()并在Socket之上做我自己的缓冲吗?还是有别的办法? 最佳答案 简而言之,不。available()不可靠(至少不适合我)。我推荐使用java.nio.channels.SocketChannel连接Se

java - 如果未调用 notify(),等待线程会发生什么情况?

如果未调用notify(),等待线程会发生什么情况?这是虚假唤醒吗? 最佳答案 如果等待线程未通过调用notify()或notifyAll()通知在所述线程正在等待的对象上,则可能发生以下任何一种情况:Thread一直在对象的等待池中等待如果指定了超时并且时间过去了,Thread将变为runnable线程被中断并再次变得可运行Thread完全没有的原因被唤醒,即它既没有被通知也没有被中断最后一种情况被称为虚假唤醒,这也是为什么Thread唤醒时应该始终检查它是否正在等待的条件的原因之一因为是真的还是假的。如果没有,Thread应该调

Java + Swing : writing code to coalesce change events

我有这个数据流,大致是:DataGenerator->DataFormatter->UIDataGenerator是一种快速生成数据的东西;DataFormatter是为了显示目的而对其进行格式化的东西;UI只是一堆Swing元素。我想让我的DataGenerator像这样:classDataGenerator{finalprivatePropertyChangeSupportpcs;...publicvoidaddPropertyChangeListener(PropertyChangeListenerpcl){this.pcs.addPropertyChangeListener(p

java - IllegalMonitorStateException notify() 和 wait()

这个问题在这里已经有了答案:JavaWaitandNotify:IllegalMonitorStateException(2个答案)关闭5年前。我有一个问题。当我在同步块(synchronizedblock)中使用notify()时,我得到IllegalMonitorStateException。谁能帮我解决这个问题?我需要一个线程向第二个线程发送一个字符,然后这个线程必须等待,第二个线程打印这个字符。在第二个线程等待之后,第一个线程再次发送下一个字符主要.java:importjava.util.logging.Level;importjava.util.logging.Logger

java - ruby 线程编程,ruby 相当于 java wait/notify/notifyAll

我想知道ruby​​有哪些方法可以替代Java方法:等待通知通知所有人您能否发布一个小片段或一些链接? 最佳答案 你要找的是Thread中的ConditionVariable:require"thread"m=Mutex.newc=ConditionVariable.newt=[]t 关于java-ruby线程编程,ruby相当于javawait/notify/notifyAll,我们在StackOverflow上找到一个类似的问题: https://stac

Java 监视器 : How to know if wait(long timeout) ended by timeout or by Notify()?

首先,这是一个几乎重复的:Howtodifferentiatewhenwait(longtimeout)exitfornotifyortimeout?但这是一个新的后续问题。有这个等待声明:publicfinalnativevoidwait(longtimeout)throwsInterruptedException;它可能会因InterruptedException或超时而退出,或者因为在另一个线程中调用了Notify/NotifyAll方法,Exception很容易捕获但是...我的代码绝对需要知道退出是超时还是通知。(以后这段代码需要重新设计,但是现在做不到,所以需要知道退出wa

java - 为什么我们需要在同一个对象上同步 notify() 才能工作

我遇到了java.lang.IllegalMonitorStateException。我提到了this问题,它解决了我的问题。第一个答案是Tobeabletocallnotify()youneedtosynchronizeonthesameobject.synchronized(someObject){someObject.wait();}/*differentthread/object*/synchronized(someObject){someObject.notify();}我的问题是为什么我们需要在同一个对象广告上同步它是如何工作的?据我所知,当我们说synchronized(

java并发: flag/event

我正在java并发类中寻找不可重置的标志或事件类,我可以用它来检查是否完成了某些事情并且是线程安全的。理想情况下是这样的:publicinterfaceEvent{/**returnstrueifsignal()hasbeencalled*/publicbooleanhasOccurred();/**returnswhensignal()hasbeencalled*/publicvoidawait();publicvoidsignal();}这样的东西已经存在了吗?我脑抽筋试图记住 最佳答案 我认为您正在寻找CountDownLat

java - 来自 Java 的 sd_notify()

我有一个Java服务(使用Dropwizard实现),我从systemd的用户实例启动它.到目前为止,一切都很好。现在我想使用systemd的notificationfeatures使其了解服务状态(可作为Clibraryfunction或shellscript使用,但最终这两种方法都与环境变量引用的套接字通信)。当服务完成启动时,我可以运行任意代码,但我不确定如何最好地从Java中通知systemd。其他开发人员在Windows上运行此服务,因此如果我的通知代码谨慎并且在不使用systemd运行时不会导致任何输出,那么对于加分来说,这将非常有用。 最佳答案