首页 > Java > java教程 > 【java基础】 线程实例

【java基础】 线程实例

黄舟
发布: 2017-02-07 10:58:08
原创
1497 人浏览过

今天有小伙伴在后台问java多线程的概念,小编觉得先从掌握基本的线程概念开始,才能更加深刻的认知多线程,通俗的讲就是多个并行运行的while循环,可以并发做多个事情,那么多个线程在实际使用过程中有可能会操作同一个数据块,那么问题多线程注意的问题就出现了。先来了解线程基本概念以及简单代码实现

Java线程学习经典例子-读写者演示

Java线程学习最经典的例子-读写者,主要用到Thread相关知识如下:

-线程的start与run

-线程的休眠(sleep)

-数据对象加锁(synchronized)

-数据对象的等待与释放(wait and notify)

程序实现:

-ObjectData数据类对象,通过synchronized关键字实现加锁,在线程读写者中使用。

-ConsumerThread消费者线程,读取数据对象中count值之后,通知生产者线程

-ProductThread生产者线程,对数据对象中count值操作,每次加1,然后通知消费者线程

类结构图如下:

931.jpg

代码实现

消费者-读线程

package com.gloomyfish.jse.thirdteen;
 
public class ConsumerThread extends Thread {
    private ObjectData data;
    public ConsumerThread(ObjectData data) {
        this.data = data;
    }
 
    @Override
    public void run() {
        while(true) {
            try {
                synchronized (data) {
                    data.wait();
                    data.read();
                    data.notify();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
 
}
登录后复制

写线程-生产者线程

package com.gloomyfish.jse.thirdteen;
 
public class ProductThread extends Thread {
    private ObjectData data;
 
    public ProductThread(ObjectData data) {
        this.data = data;
    }
 
    @Override
    public void run() {
        while (true) {
            try {
                synchronized (data) {
                    data.write();
                    Thread.sleep(3000);
                    data.notify();
                    data.wait();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
 
}
登录后复制

数据对象类

package com.gloomyfish.jse.thirdteen;
 
public class ObjectData {
 
    private int count;
     
    public ObjectData() {
        count = 0;
    }
     
    public void read() {
        System.out.println("read count : " + count);
        System.out.println();
    }
     
    public void write() {
        count++;
        System.out.println("write count : " + count);
    }
}
登录后复制

测试代码:

public static void main(String[] args) {
        ObjectData data = new ObjectData();
        ConsumerThread ct = new ConsumerThread(data);
        ProductThread pt = new ProductThread(data);
 
        ct.start();
        pt.start();
}
登录后复制

总结:

示例程序代码完成了线程之间如何通过wait与notify实现数据的读写

同步控制。演示了Java的同步关键字synchronized的用法与线程的用法。

以上就是【java基础】 线程实例的内容,更多相关内容请关注PHP中文网(m.sbmmt.com)!


相关标签:
来源:php.cn
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板