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

java多线程（转载）二

 
阅读更多

 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
/**
 * @author Rollen-Holt 线程的优先级
 * */
class hello implements Runnable {
    public void run() {
        for(int i=0;i<5;++i){
            System.out.println(Thread.currentThread().getName()+"运行"+i);
            if(i==3){
                System.out.println("线程的礼让");
                Thread.currentThread().yield();
            }
        }
    }
 
    public static void main(String[] args) {
        Thread h1=new Thread(new hello(),"A");
        Thread h2=new Thread(new hello(),"B");
        h1.start();
        h2.start();
         
    }
}

A运行0

A运行1

A运行2

A运行3

线程的礼让

A运行4

B运行0

B运行1

B运行2

B运行3

线程的礼让

B运行4

 

 

同步和死锁：

【问题引出】:比如说对于买票系统，有下面的代码：

?
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
/**
 * @author Rollen-Holt
 * */
class hello implements Runnable {
    public void run() {
        for(int i=0;i<10;++i){
            if(count>0){
                try{
                    Thread.sleep(1000);
                }catch(InterruptedException e){
                    e.printStackTrace();
                }
                System.out.println(count--);
            }
        }
    }
 
    public static void main(String[] args) {
        hello he=new hello();
        Thread h1=new Thread(he);
        Thread h2=new Thread(he);
        Thread h3=new Thread(he);
        h1.start();
        h2.start();
        h3.start();
    }
    private int count=5;
}

【运行结果】：

5

4

3

2

1

0

-1

这里出现了-1，显然这个是错的。，应该票数不能为负值。

如果想解决这种问题，就需要使用同步。所谓同步就是在统一时间段中只有有一个线程运行，

其他的线程必须等到这个线程结束之后才能继续执行。

【使用线程同步解决问题】

采用同步的话，可以使用同步代码块和同步方法两种来完成。

 

【同步代码块】：

语法格式：

synchronized（同步对象）{

 //需要同步的代码

}

但是一般都把当前对象this作为同步对象。

比如对于上面的买票的问题，如下：

?
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
/**
 * @author Rollen-Holt
 * */
class hello implements Runnable {
    public void run() {
        for(int i=0;i<10;++i){
            synchronized (this) {
                if(count>0){
                    try{
                        Thread.sleep(1000);
                    }catch(InterruptedException e){
                        e.printStackTrace();
                    }
                    System.out.println(count--);
                }
            }
        }
    }
 
    public static void main(String[] args) {
        hello he=new hello();
        Thread h1=new Thread(he);
        Thread h2=new Thread(he);
        Thread h3=new Thread(he);
        h1.start();
        h2.start();
        h3.start();
    }
    private int count=5;
}

【运行结果】：（每一秒输出一个结果）

5

4

3

2

1

【同步方法】

也可以采用同步方法。

语法格式为synchronized 方法返回类型方法名（参数列表）{

    // 其他代码

}

现在，我们采用同步方法解决上面的问题。

?
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
/**
 * @author Rollen-Holt
 * */
class hello implements Runnable {
    public void run() {
        for (int i = 0; i < 10; ++i) {
            sale();
        }
    }
 
    public synchronized void sale() {
        if (count > 0) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(count--);
        }
    }
 
    public static void main(String[] args) {
        hello he = new hello();
        Thread h1 = new Thread(he);
        Thread h2 = new Thread(he);
        Thread h3 = new Thread(he);
        h1.start();
        h2.start();
        h3.start();
    }
 
    private int count = 5;
}

【运行结果】（每秒输出一个）

5

4

3

2

1

提醒一下，当多个线程共享一个资源的时候需要进行同步，但是过多的同步可能导致死锁。

此处列举经典的生产者和消费者问题。

【生产者和消费者问题】

先看一段有问题的代码。

?
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
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;
    }
 
    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.setName("Rollen");
                try{
                    Thread.sleep(100);
                }catch (Exception e) {
                    e.printStackTrace();
                }
                this.info.setAge(20);
                flag=false;
            }else{
                this.info.setName("chunGe");
                try{
                    Thread.sleep(100);
                }catch (Exception e) {
                    e.printStackTrace();
                }
                this.info.setAge(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();
            }
            System.out.println(this.info.getName()+"<---->"+this.info.getAge());
        }
    }
}
 
/**
 * 测试类
 * */
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<---->100

chunGe<---->20

chunGe<---->100

Rollen<---->100

chunGe<---->20

Rollen<---->100

Rollen<---->100

Rollen<---->100

chunGe<---->20

chunGe<---->20

chunGe<---->20

Rollen<---->100

chunGe<---->20

Rollen<---->100

chunGe<---->20

Rollen<---->100

chunGe<---->20

Rollen<---->100

chunGe<---->20

Rollen<---->100

chunGe<---->20

Rollen<---->100

chunGe<---->20

Rollen<---->100

chunGe<---->20

大家可以从结果中看到，名字和年龄并没有对齐。

 


 

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

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

相关推荐

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

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

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

    2. **多线程处理**： - **并发处理**：在聊天软件中，通常需要同时处理多个客户端的连接和消息发送，因此多线程技术至关重要。Java提供了Thread类以及Runnable接口来支持多线程编程。 3. **IO流**： - **输入输出...

    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编写弹跳的小球源代码（转载）

    2. **性能优化**：对于大量计算的任务（如`move`方法中未使用的循环），应考虑将其放在独立的线程中执行，以免影响主程序的流畅度。 3. **用户交互**：增加更多的用户交互功能，比如允许用户调整小球的颜色、速度等...

    深入分析 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 深入剖析与实例应用.part2

    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