`
wb284551926
  • 浏览: 551393 次
文章分类
社区版块
存档分类
最新评论

java多线程（转载）三

java多线程 
阅读更多


那么如何解决呢？

1）加入同步

2）加入等待和唤醒

先来看看加入同步会是如何。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
class Info {
     
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public int getAge() {
        return age;
    }
 
    public void setAge(int age) {
        this.age = age;
    }
 
    public synchronized void set(String name, int age){
        this.name=name;
        try{
            Thread.sleep(100);
        }catch (Exception e) {
            e.printStackTrace();
        }
        this.age=age;
    }
     
    public synchronized void get(){
        try{
            Thread.sleep(100);
        }catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println(this.getName()+"<===>"+this.getAge());
    }
    private String name = "Rollen";
    private int age = 20;
}
 
/**
 * 生产者
 * */
class Producer implements Runnable {
    private Info info = null;
 
    Producer(Info info) {
        this.info = info;
    }
 
    public void run() {
        boolean flag = false;
        for (int i = 0; i < 25; ++i) {
            if (flag) {
                 
                this.info.set("Rollen", 20);
                flag = false;
            } else {
                this.info.set("ChunGe", 100);
                flag = true;
            }
        }
    }
}
 
/**
 * 消费者类
 * */
class Consumer implements Runnable {
    private Info info = null;
 
    public Consumer(Info info) {
        this.info = info;
    }
 
    public void run() {
        for (int i = 0; i < 25; ++i) {
            try {
                Thread.sleep(100);
            } catch (Exception e) {
                e.printStackTrace();
            }
            this.info.get();
        }
    }
}
 
/**
 * 测试类
 * */
class hello {
    public static void main(String[] args) {
        Info info = new Info();
        Producer pro = new Producer(info);
        Consumer con = new Consumer(info);
        new Thread(pro).start();
        new Thread(con).start();
    }
}

【运行结果】：

Rollen<===>20

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

Rollen<===>20

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

ChunGe<===>100

从运行结果来看，错乱的问题解决了，现在是Rollen 对应20，ChunGe对于100

，但是还是出现了重复读取的问题，也肯定有重复覆盖的问题。如果想解决这个问题，就需要使用Object类帮忙了、

，我们可以使用其中的等待和唤醒操作。

要完成上面的功能，我们只需要修改Info类饥渴，在其中加上标志位，并且通过判断标志位完成等待和唤醒的操作，代码如下：

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
class Info {
     
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public int getAge() {
        return age;
    }
 
    public void setAge(int age) {
        this.age = age;
    }
 
    public synchronized void set(String name, int age){
        if(!flag){
            try{
                super.wait();
            }catch (Exception e) {
                e.printStackTrace();
            }
        }
        this.name=name;
        try{
            Thread.sleep(100);
        }catch (Exception e) {
            e.printStackTrace();
        }
        this.age=age;
        flag=false;
        super.notify();
    }
     
    public synchronized void get(){
        if(flag){
            try{
                super.wait();
            }catch (Exception e) {
                e.printStackTrace();
            }
        }
         
        try{
            Thread.sleep(100);
        }catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println(this.getName()+"<===>"+this.getAge());
        flag=true;
        super.notify();
    }
    private String name = "Rollen";
    private int age = 20;
    private boolean flag=false;
}
 
/**
 * 生产者
 * */
class Producer implements Runnable {
    private Info info = null;
 
    Producer(Info info) {
        this.info = info;
    }
 
    public void run() {
        boolean flag = false;
        for (int i = 0; i < 25; ++i) {
            if (flag) {
                 
                this.info.set("Rollen", 20);
                flag = false;
            } else {
                this.info.set("ChunGe", 100);
                flag = true;
            }
        }
    }
}
 
/**
 * 消费者类
 * */
class Consumer implements Runnable {
    private Info info = null;
 
    public Consumer(Info info) {
        this.info = info;
    }
 
    public void run() {
        for (int i = 0; i < 25; ++i) {
            try {
                Thread.sleep(100);
            } catch (Exception e) {
                e.printStackTrace();
            }
            this.info.get();
        }
    }
}
 
/**
 * 测试类
 * */
class hello {
    public static void main(String[] args) {
        Info info = new Info();
        Producer pro = new Producer(info);
        Consumer con = new Consumer(info);
        new Thread(pro).start();
        new Thread(con).start();
    }
}
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
【程序运行结果】：
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
ChunGe<===>100
Rollen<===>20
先在看结果就可以知道，之前的问题完全解决。

 

分享到：
| java多线程（转载）二
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    Java多线程编程总结(java 1.6版)

    1.8版还有更多新特性 原创作品，允许转载，转载时请务必以超链接形式标明文章 原始出处 、作者信息和本声明。否则将追究法律责任。http://lavasoft.blog.51cto.com/62575/27069

    【转载】java实现的局域网聊天软件

    【Java 实现局域网聊天软件...综上所述，构建一个Java实现的局域网聊天软件涉及众多技术，包括Java网络编程、多线程、IO流、Spring Boot框架、WebSocket、JSON数据交换等，开发者需要对这些知识有深入理解和实践能力。

    java面试资料（转载）

    首先，多线程是Java中的一个关键特性，它允许程序同时执行多个任务，提高系统的效率和响应性。Java提供了多种方式来创建和管理线程，如通过实现Runnable接口或继承Thread类。理解线程生命周期（新建、就绪、运行、...

    java编程事项(转载收集整理版)

    5. **多线程**：Java提供了内置的多线程支持，通过Thread类和Runnable接口可以创建并管理线程。理解线程同步（如synchronized关键字和Lock接口）以及并发工具类（如ExecutorService和Future）是处理并发问题的关键。...

    java基于socket聊天室源代码.rar

    java基于socket聊天室源代码.rar 注：供java socket编程的初学者学习使用，严禁用作作业抄袭和商业用途。若转载源代码，请注明原作者以及作者的博客地址。 项目名称：...单播，解决了多线程同步的问题。

    Java工程师新人入门书籍推荐

    - 《深入理解Java虚拟机：JVM高级特性与最佳实践》：周志明的书，深入讲解JVM内存模型和多线程，对并发编程有较大帮助。 - 《Java EE 6 权威指南．基础篇．Basic concepts》：尽管现代开发更多依赖Spring等框架，...

    java编写弹跳的小球源代码（转载）

    3. **用户交互**：增加更多的用户交互功能，比如允许用户调整小球的颜色、速度等。 4. **代码规范**：遵循Java编码规范，提高代码可读性和维护性，例如正确缩进、合理命名变量和方法等。 通过以上分析可以看出，该...

    深入分析 Java I/O 的工作机制(转载)

    NIO允许单线程处理多个通道，提高了服务器端并发性能。 8. **文件操作** Java的File类提供了对文件和目录的操作，如创建、删除、重命名等。FileInputStream和FileOutputStream用于读写文件，而FileReader和...

    java编程思想习题及答案

    6. **多线程**：学习如何创建和管理线程，理解同步机制，如synchronized关键字、wait()、notify()等。通过习题，可以实践多线程编程，解决并发问题。 7. **反射**：掌握Java反射机制，能够动态地获取类的信息并调用...

    java并发编程教程源码

    并发编程的意义及影响多线程的因素 并发编程的目的是为了让程序运行得更快，但是，并不是启动更多的线程就能让程序最大限度地并发执行。 影响多线程运行速度的原因有线程创建开销、上下文切换、死锁，以及硬件和软件...

    抽奖软件java

    2. **线程**：为了实现抽奖过程的实时性和流畅性，软件通常会使用多线程。Java提供了Thread类和Runnable接口来创建和管理线程。在这个案例中，可能会有一个线程负责用户界面的更新，另一个线程负责抽奖逻辑，确保...

    Java 最常见 200+ 面试题全解析：面试必备.pdf

    3. 多线程：介绍线程的创建和管理，线程同步机制，如synchronized关键字，wait和notify方法，以及线程池的使用。 4. 反射：讨论Java反射机制，它允许程序在运行时访问和修改类的行为，是框架开发中的重要技术。 5....

    Java面试题

    Java作为一门广泛使用的编程语言，其面试题涵盖了众多的知识领域，包括基础语法、面向对象、集合框架、多线程、异常处理、IO流、网络编程、设计模式、JVM优化、数据库操作等。以下是一些Java面试中常被问到的知识点...

    Java 9 High Performance

    在IT行业中，Java是一种广泛使用、面向对象的编程语言，以其跨平台、多线程和安全性著称。而Java 9作为Java语言的第九个主要版本，于2017年9月21日发布，它不仅包含了语言上的新特性，还包含了JDK（Java开发工具包）...

    Java程序员面试的试题集（1_122）帮助初学者的技术问题(转载)

    与CGI（Common Gateway Interface）相比，Servlet 运行在服务器的进程中，通过多线程方式处理请求，因此效率更高，因为不需要为每个请求创建新的进程。Servlet 实例通常在整个应用运行期间保持活动状态，这使其能够...

    JAVA WEB 开发详解：XML+XSLT+SERVLET+JSP 深入剖析与实例应用.part3

    11.1 多线程的servlet模型 350 11.2 线程安全的servlet 351 11.2.1 变量的线程安全 351 11.2.2 属性的线程安全 360 11.3 singlethreadmodel接口 362 11.4 小结 363 11.5 思考题 363 第3部分 jsp篇 第12章 ...

    java 课设-超级玛丽游戏

    声明：未经允许，请勿转载 本程序是针对超级玛丽小游戏的 JAVA 程序，进入游戏后首先用鼠标点击 GUI 窗口，然后开始游 戏...利用多线程技术，给游戏分别添加背景音乐、 跳跃音乐、死亡音乐、顶金币音乐、游戏胜利音乐。

    基于Socket的分布计算实例java源代码

    1、供java socket编程的初学者学习使用，严禁用作作业抄袭和商业用途。若转载源代码，请注明原作者以及作者的博客地址。 2、TCPChatRoomServer（服务器端）,TCPChatRoomClient...单播，解决了多线程同步的问题。

Magicbox
Global site tag (gtag.js) - Google Analytics