今天有小伙伴在后台问java多线程的概念,小编觉得先从掌握基本的线程概念开始,才能更加深刻的认知多线程,通俗的讲就是多个并行运行的while循环,可以并发做多个事情,那么多个线程在实际使用过程中有可能会操作同一个数据块,那么问题多线程注意的问题就出现了。先来了解线程基本概念以及简单代码实现
java线程学习经典例子-读写者演示
java线程学习最经典的例子-读写者,主要用到thread相关知识如下:
-线程的start与run
-线程的休眠(sleep)
-数据对象加锁(synchronized)
-数据对象的等待与释放(wait and notify)
程序实现:
-objectdata数据类对象,通过synchronized关键字实现加锁,在线程读写者中使用。
-consumerthread消费者线程,读取数据对象中count值之后,通知生产者线程
-productthread生产者线程,对数据对象中count值操作,每次加1,然后通知消费者线程
类结构图如下:
代码实现
消费者-读线程
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基础】 线程实例的内容。