java多线程观察者模式如何实现？

已采纳

假设有一个对象subject和500个观察者；
当对象有更新信息时通知500个观察者，
因担心循环通知耗时过久，考虑在通知时使用多个
线程进行通知。
以上功能应该如何实现？

点赞
写回答
关注问题
收藏
复制链接分享
邀请回答

8条回答

采纳
码龄粉丝数

被点赞

被采纳

采纳率

私信
从今以后生命中的每一秒都属于我爱的人 3年前
观察者模式本身没有必要多线程。
你需要将通知和对象的处理分离，可以每个对象拥有一个消息队列，发送通知的时候添加消息到对象的消息列表中。
500个对象乃至·10000个对象都可以很快发送。而每个对象自己读取消息列表后处理，这个放在多线程中完成。这么做的好处是，每个对象的消息列表是单独同步的，因此没有需要全局加锁的对象，才能发挥多线程的最大的优势。

点赞 1 评论复制链接分享
采纳
码龄粉丝数

被点赞

被采纳

采纳率

私信
jxiaolu 3年前
可以参考：
https://blog.csdn.net/mastershaw/article/details/71271862?utm_source=itdadao&utm_medium=referral

点赞 1 评论复制链接分享
采纳
码龄粉丝数

被点赞

被采纳

采纳率

私信
limeigui 3年前
1、首先观察者模式本身，不区分是否多线程。

2、观察者模式：就是订阅分发机制，通过实现注册哪些接口实现类所关注的动作。然后再出发时，分别回调就可以。原理示意代码：

interface IMyAction
{
DoAction();
}
```
；
```
class ObserManager
{
private List list = new List;
```
        public bool Subsribe(IMyAction action)
        {
            list.Add(action);
        }

        public bool DoAction()
        {
            foreach(IMyAction action in  list)
            {
                action.DoAction();
            }
        }
 }
```
点赞评论复制链接分享
采纳
码龄粉丝数

被点赞

被采纳

采纳率

私信
Royal_lr 3年前
你就是想用多线程做通知而已，直接
int threadNum=30;
ExecutorService pool=Executors.newFixedThreadPool(threadNum);
pool.execute(new Runnable() {
@Override
public void run() {
执行通知
}
});
线程池做通知就行了

点赞评论复制链接分享
采纳
码龄粉丝数

被点赞

被采纳

采纳率

私信
qq_41399931 3年前
把500个观察者分成5段，每个线程发送100通知

点赞评论复制链接分享
采纳
码龄粉丝数

被点赞

被采纳

采纳率

私信
ZhihengTao 3年前
首先 "循环通知耗时过久" 这个问题是否存在都是未知, 需要先确定问题存在,再讨论如何解决问题才有意义

建议

先测定循环耗时,确定问题存在与否
- 循环前后计时
- 循环内只做**同步的**消息通知操作,不做**同步的**消息处理操作
如果问题不存在,皆大欢喜,不用管了.

如果问题存在,那就需要确定其瓶颈所在, 假定瓶颈在循环体内某个操作,可以考虑循环体内操作在多线程下进行.

多线程

但是多线程可能会带来其他开销,如线程创建,线程销毁,消息同步等. 一般M任务N线程**(M >> N)**问题,可以考虑**线程池**模型.
假定问题存在的情况下, 最终是否采用多线程,也还是要根据性能瓶颈,比较采用前后开销大小来决定.

关键
1. 问题存在与否
2. 问题存在时,瓶颈在哪里
点赞评论复制链接分享
采纳
码龄粉丝数

被点赞

被采纳

采纳率

私信
qq_36238292 3年前
比如5个线程，把500个观察者分成5段，每个线程发送100通知。

点赞评论复制链接分享

水里的魚儿 3年前

Observable notifyObservers( )方法获取是否改变，改变的话，依次通知所有观察者（即循环调用所有观察的update（）方法）；
1、在Observer的 update（）实现线程；
public void update（）{
Runnable mRunnable = new Runnable(
public void run() {
/**Task**/
}
);

Thread mThread = new Thread(mTestRunnable);
mThread.start();
}

2、覆写Observable notifyObservers( )方法；
public void notifyObservers(Object arg) {
/*
* a temporary array buffer, used as a snapshot of the state of
* current Observers.
*/
Object[] arrLocal;

    synchronized (this) {
        /* We don't want the Observer doing callbacks into
         * arbitrary code while holding its own Monitor.
         * The code where we extract each Observable from
         * the Vector and store the state of the Observer
         * needs synchronization, but notifying observers
         * does not (should not).  The worst result of any
         * potential race-condition here is that:
         * 1) a newly-added Observer will miss a
         *   notification in progress
         * 2) a recently unregistered Observer will be
         *   wrongly notified when it doesn't care
         */
        if (!changed)
            return;
        arrLocal = obs.toArray();
        clearChanged();
    }

    for (int i = arrLocal.length-1; i>=0; i--)//在这里调用线程，然后在线程再调用观察者的update（）方法；
        ((Observer)arrLocal[i]).update(this, arg);
}

点赞评论复制链接分享

提交

相关推荐

java多线程观察者模式如何实现？ java
3年前

回答 8 已采纳假设有一个对象subject和500个观察者；当对象有更新信息时通知500个观察者，因担心循环通知耗时过久，考虑在通知时使用多个线程进行通知。以上功能应该如何实现？
java 多线程为什么锁没用？ java
4年前

回答 6 已采纳 public class ThreadsTest { public static void main(String[] args) { Threads tsa=new Threads(); Threads tss=new Threads(); Threads tsd=new Threads(); Threads tsf=new Threads(); Threads tsg=new Threads(); Thread ts1=new Thread(tsa, "线程1"); Thread ts2=new Thread(tss, "线程2"); Thread ts3=new Thread(tsd, "线程3"); Thread ts4=new Thread(tsf, "线程4"); Thread ts5=new Thread(tsg, "线程5"); ts1.start(); ts2.start(); ts3.start(); ts4.start(); ts5.start(); } } package com.huadian.bean; public class Threads implements Runnable{ private int str=5; public Threads(int str) { super(); this.str = str; } public Threads() { super(); } @Override public void run() { synchronized (Threads.class) { for(int i=0;i<str;i++){ System.out.println(Thread.currentThread().getName()+"___"+i); if(i==3){ try { System.out.println(Thread.currentThread().getName()+"___"+"休息休息-----------------------------"); Thread.sleep(1000); // Threads.class.notifyAll(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } } }
java多线程是如何运作的？ java
4年前

回答 2 已采纳假如我创建了两个线程，加上main方法就是3个线程，线程间会互相抢资源，抢到资源的那个线程，他是如何执行它的程序？由上往下执行？还是随机选择一行执行？
java多线程编程一定要用sleep方法才能实现吗？ java
4年前

回答 5 已采纳 java多线程编程一定要用sleep方法才能实现吗？我编程时用sleep方法结果正常，但是把sleep方法去掉就乱了，设置flag也没有用。请帮忙解释下。
java多线程如何让一个线程只执行一次？ java
4年前

回答 4 已采纳 java多线程如何让一个线程只执行一次？我目前只能是检测到getname（）然后用wait（）方法。想知道还有没其他方法？ ``` public class TicketSale { public static void main(String[] args) { Runnable r1=new Ticket(); Thread t1=new Thread(r1); Thread t2=new Thread(r1); Thread t3=new Thread(r1); t1.setName("黄牛党"); t2.setName("桃跑跑"); t3.setName("张票票"); t1.start(); t2.start(); t3.start(); } } class Ticket implements Runnable{ private int ticket=10; private int num=1; public synchronized void sale(){ try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } if(ticket>0){ System.out.println(Thread.currentThread().getName()+"抢到第"+(num++)+ "张票。剩余"+((ticket--)-1)+"张票。"); } if(ticket==0){ notify(); System.out.println("票已全部售完"); } if("黄牛党".equals(Thread.currentThread().getName())){ Thread.currentThread().interrupted(); } } @Override public void run() { while(num<10){ sale(); } } } ```
Java何种业务才会用到多线程？如果是并发如何实现？ java
1年前

回答 2 已采纳本人虽然已经是个3年的码农了，但是业务都是在SSM中度过，单机加个Nginx或者Redis，最多再加个MQ，差不多就几乎承包了我所有的代码量。除去做过一个JT808的车船定位报文解析（应该是多线程的），其他未接触到需要运用到多线程或者去解决并发的问题。我想询问下大佬，什么时候怎么样的业务会运用到多线程去处理（定时器，上报，迁移？如果是业务层面呢）。万分感激
Java项目中什么时候需要多线程？ java
4年前

回答 23 已采纳 Java项目中什么时候需要多线程？比如什么项目中那个模块用到了
java如何使用Socket实现多线程多人聊天 java
6年前

回答 5 已采纳 java如何使用Socket实现多线程多人聊天，提供源码最好了。希望说详细一点。
学习java时多用户登录，教材里说采用多线程实现。那么如何实现线程之间的通讯呢？ java
4年前

回答 2 已采纳学习java时多用户登录，教材里说采用多线程实现。那么如何实现线程之间的通讯呢？也就是客户端与客户端的通讯？最好能给个小例子？
java接口与多线程的问题 java
4年前

回答 3 已采纳 public class ThreadPool { Lock lock = new ReentrantLock();//为什么要用这种形式 ReentrantLock ren=new ReentrantLock();//这样写有什么不一样吗？ }
super 的一个小的问题希望得到确认 Java核心技术卷一 java
4年前

回答 2 已采纳 ![图片说明](https://img-ask.csdn.net/upload/201708/13/1502587221_576508.png) 在主函数中,有语句 System.out.println("carl.equals(boss): " + carl.equals(boss)); 也就是说 carl.equals(boss), 到manager函数中有 ``` public boolean equals(Object otherObject) { if (!super.equals(otherObject)) return false; Manager other = (Manager) otherObject; // super.equals checked that this and other belong to the same class return bonus == other.bonus; } ``` 这个super是调用父类中的方法,也就是说carl和boss先调用父类中的这个方法进行比较,这个是对的吗?
java核心技术卷一 equals方法 EqualTest.java java
4年前

回答 4 已采纳 ``` public class EqualTest { public static void main(String[] args) { Employee alice1 = new Employee("Alice Adams", 75000, 1989, 12, 15); Employee alice2 = alice1; Employee alice3 = new Employee("Alice Adams", 75000, 1989, 12, 15); Employee bob = new Employee("Bob Brandson", 50000, 1989, 10, 1); System.out.println("alice1 == alice2: "+(alice1==alice2)); System.out.println("alice1 == alice3: "+(alice1==alice3)); System.out.println("alice1.equals(alice3): "+alice1.equals(alice3)); System.out.println("alice1.equals(bob): "+alice1.equals(bob)); System.out.println("bob.toString(): "+bob); Manager car1 = new Manager("Carl Cracker", 80000, 1987, 12, 15); Manager boss = new Manager("Carl Cracker", 80000, 1987, 12, 15); boss.setBonus(5000); System.out.println("boss.toString(): "+boss); System.out.println("carl.equals(boss): "+car1.equals(boss)); System.out.println("alice1.hashCode(): "+alice1.hashCode()); System.out.println("alice3.hashCode(): "+alice3.hashCode()); System.out.println("bob.hashCode(): "+bob.hashCode()); System.out.println("car1.hashCode(): "+car1.hashCode()); } } import java.util.Date; import java.util.GregorianCalendar; import java.util.Objects; public class Employee { private String name; private double salary; private Date hireDay; public Employee(String n,double s,int year,int month,int day){ name = n; salary = s; GregorianCalendar calendar = new GregorianCalendar(year,month-1,day); hireDay = calendar.getTime(); } public String getName(){ return name; } public double getSalary(){ return salary; } public Date getHireDay(){ return hireDay; } public void raiseSalary(double byPercent){ double raise = salary * byPercent / 100; salary += raise; } public boolean equals(Object otherObject){ //这里获得一个对象参数，第一个if语句判断两个引用是否是同一个，如果是那么这两个对象肯定相等 if(this == otherObject) return true; //这里判断这个参数是否引用空值 if(otherObject == null) return false; //getClass()方法是得到对象的类，这里就是如果两个对象的类不一样，那么就不相等 if(getClass()!=otherObject.getClass()) return false; //在以上判断完成，再将得到的参数对象强制转换为该对象，考虑到父类引用子类的对象的出现，然后再判断对象的属性是否相同 Employee other = (Employee)otherObject; return Objects.equals(name, other.name)&&salary ==other.salary&& Objects.equals(hireDay, other.hireDay); } //哈希散列，有自己的计算方法，根据字符串来得到一段数字 public int hashCode(){ return Objects.hash(name,salary,hireDay); } //toString()方法，可自动生成 @Override public String toString() { return getClass().getName()+ "[name=" + name + ", salary=" + salary + ", hireDay=" + hireDay + "]"; } } public class Manager extends Employee { private double bonus; public Manager(String n,double s, int year,int month,int day){ super(n, s, year, month, day); bonus = 0; } public double getSalary(){ double baseSalary = super.getSalary(); return baseSalary + bonus; } public void setBonus(double b){ bonus = b; } public boolean equals(Object otherObject){ if(!super.equals(otherObject)) return false; Manager other = (Manager)otherObject; return bonus == other.bonus; } public int hashCode(){ return super.hashCode()+17*new Double(bonus).hashCode(); } public String toString(){ return super.toString()+"[bonus=]"+bonus+"]"; } } ``` 这个程序里面有一部分，是public boolean equals（object otherObject）方法，在这个方法的return语句里面莫名其妙的出现了一个Object.equals(a,b),我不明白这个是从哪里来的，求大神解释一下。
多线程下的观察者模式--Java实现
4年前

GPU小码农的博客按照我的理解，观察者模式使用的场景：假如现在有一个土匪，绑架了一名重要人质，目前躲在一个楼房里，楼房四周已经被警察包围，还有特种部队，狙击手。观察者模式是这样运作的：目前场景中的观察者是：警察、防暴队...
多线程——9多线程实现观察者模式任务
1年前

黄国余的博客实现对一批id进行多线程的并行处理，处理完成之后需要得到处理结果如： [1,2,5,8,11,22,44], 这一批id被三个线程执行更新操作，执行完成之后需要得到执行的结果实现定义观察者接口此方法是当任务执行完成时...
如何使用 Java8 实现观察者模式？（下）
5年前

OneAPM官方技术的博客【编者按】本文作者是 BAE 系统公司的软件工程师 Justin Albano。...线程安全的实现前面章节介绍了在现代Java环境下的实现观察者模式，虽然简单但很完整，但这一实现忽略了一个关键性问题：线程安全。大
如何使用 Java8 实现观察者模式？（上）
5年前

OneAPM官方技术的博客本文主要介绍通过使用 Java8 架构实现观察者模式，并在此基础上进一步探讨关于经典模式的复杂问题，包括匿名内部类、lambda 表达式、线程安全以及非平凡耗时长的观察者实现。本文内容虽然并不全面，很多这种模式所...
java 线程意外中断重启处理办法(观察者模式)
2年前

wgxhpr的博客使用观察者模式具体代码首先线程需要继承Observable public class TestServer extends Observable implements Runnable { private static Logger logger = LoggerFactory.getLogger(TestServer.class); .....
多线程之设计模式之Listener设计模式(观察者设计模式)
3年前

一只想飞的猪猪的博客观察者模式（有时又被称为模型-视图（View）模式、源-收听者(Listener)模式或从属者模式）是软件设计模式的一种。在此种模式中，一个目标物件管理所有相依于它的观察者物件，并且在它本身的状态改变时主动发出通知。...
Java面试题大全（2020版）
2年前

Java程序员-张凯的博客发现网上很多Java面试题都没有答案，所以花了很长时间搜集整理出来了这套Java面试题大全，希望对大家有帮助哈~ 本套Java面试题大全，全的不能再全，哈哈~ 一、Java 基础 1. JDK 和 JRE 有什么区别？ JDK：Java ...
Java设计模式实战 ~ 观察者模式分析与实战
2年前

Chiclaim的博客本文主要介绍了观察者模式的原理、使用场景、JDK中的观察者模式、观察者模式的缺点、最后介绍了观察者模式在项目中的实践

wild84

java多线程观察者模式如何实现？

8条回答

建议

多线程

关键

相关推荐