Java多线程高并发学习笔记(一)——Thread&Runnable

简介: 进程与线程 首先来看百度百科关于进程的介绍: 进程是一个具有独立功能的程序关于某个数据集合的一次运行活动。它可以申请和拥有系统资源,是一个动态的概念,是一个活动的实体。它不只是程序的代码,还包括当前的活动,通过程序计数器的值和处理寄存器的内容来表示。

 进程与线程

首先来看百度百科关于进程的介绍:

进程是一个具有独立功能的程序关于某个数据集合的一次运行活动。它可以申请和拥有系统资源,是一个动态的概念,是一个活动的实体。它不只是程序的代码,还包括当前的活动,通过程序计数器的值和处理寄存器的内容来表示。 

直观一点:

 

 

windows的任务管理里面,我们看到的eclipse和360等等,都是进程。(想深入了解的可以看看计算机操作系统)

什么是线程?

线程是在一个进程独立运行的子任务。线程是进程中的一个实体,是被系统独立调度和分派的基本单位,线程自己不拥有系统资源,只拥有一点儿在运行中必不可少的资源,但它可与同属一个进程的其它线程共享进程所拥有的全部资源。

打个比如说,我们都用的QQ软件,它是一个进程,我们可以和人一边聊天一边传输文件,这就是多线程。

为什么要使用多线程?

1.多线程可以充分的利用系统的cpu,达到更快的处理效果

2.提高系统的运行效率

想入更深入了解的可以重新学习计算机操作系统,这里就不多介绍了,接下来我们怎么用!(毕竟这才是关键)

 

Thread and Runnable

Java中实现线程有两个方式,一个是继承Thread,另一个是实现Runnable接口,首先来看继承Thread的第一个实例:

package com.chapter1;

public class FirstThread {

    public static void main(String[] args) {
        InnerThread thread = new InnerThread();
        // 线程启动
        thread.start();
    }

}

class InnerThread extends Thread {

    // Override run方法,写入自己想要实现的业务
    @Override
    public void run() {
        super.run();
        System.out.println("Hello World!");
    }
}

 继承run方法的时候,我们通常会重写run方法,来实现自己的业务,接下来看,如何使用Runnable实现线程:

package com.chapter1;

public class FirstRunnable {

    public static void main(String[] args) {
        MyRunnable myRunnable;
        myRunnable = new MyRunnable();
        new Thread(myRunnable).start();
    }

}

class MyRunnable implements Runnable {

    @Override
    public void run() {
        System.out.println("Hello World!");
    }
}

Runnable是一个接口,接口意味着更加灵活一些,也是推荐使用实现Runable接口来写线程的。

 现在我们看到的都是一个单线程的例子,接下来写一个多线程的:

 

package com.chapter1;
/**
 * 多个线程实例
 * @author tangj
 *
 */
public class ManyThread {

    public static void main(String args[]) {
        Runnable runnable = new MyRunnable2();
        new Thread(runnable, "a").start();
        new Thread(runnable, "b").start();
        new Thread(runnable, "c").start();
        new Thread(runnable, "d").start();
    }
}

class MyRunnable2 implements Runnable {

    int count = 0;
    @Override
    public void run() {
        autoIncrement();
        System.out.println(Thread.currentThread().getName()+"计算了"+"count:" + count);
    }
    // 执行自增操作
    private void autoIncrement(){
        count++;
    }
}

我们来看下运行结果:

 

再运行一次

可以看到,多线程的执行是无序的,而且这个结果有点奇怪,难道不是从1增加到4吗,怎么会出现重复的?

在JVM中,执行自增操作的分为三个步骤:

1.取得现有值count

2.执行count+1操作

3.将count+1赋值给count.

所以就会遇到这样的情况,一个线程在取得count值的时候,count操作正处于第二个步骤,上一个线程执行的还未进行赋值操作,这就涉及到线程安全问题。

 

下面给出上一个例子的解决方案                                                               

package com.chapter1;

/**
 * 多个线程实例
 * 
 * @author tangj
 *
 */
public class ManyThread {

    public static void main(String args[]) {
        Runnable runnable = new MyRunnable2();
        new Thread(runnable, "a").start();
        new Thread(runnable, "b").start();
        new Thread(runnable, "c").start();
        new Thread(runnable, "d").start();
    }
}

class MyRunnable2 implements Runnable {

    int count = 0;

    // 注意在这里增加了关键字 synchronized
    @Override
    synchronized public void run() {
        autoIncrement();
        System.out.println(Thread.currentThread().getName() + "计算了" + "count:" + count);
    }

    // 执行自增操作
    private void autoIncrement() {
        count++;
    }
}

来看输出结果(多执行几次):

我们可以看到:不管哪个线程先执行,最后的打印顺序肯定是递增的顺序。

 

 接下来我们看另外一中实现方式:使用重入锁(ReentrantLock)

package com.chapter1;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ManyThread2 {

    public static void main(String[] args) {
        Runnable runnable = new MyRunnable3();
        new Thread(runnable, "a").start();
        new Thread(runnable, "b").start();
        new Thread(runnable, "c").start();
        new Thread(runnable, "d").start();
    }
}

class MyRunnable3 implements Runnable{
    
    int count = 0;
    // 使用重入锁ReentrantLock
    Lock lock = new ReentrantLock();
    
    @Override
    public void run() {
        // 锁住
        lock.lock();
        count++;
        System.out.println(Thread.currentThread().getName() + "计算了" + "count:" + count);
        // 解锁
        lock.unlock();
    }
    
}

得到的结果也是整齐的递增顺序,说明它也是线程安全的。

 

总结

所以以后开发多线程的业务的时候,首先应该考虑的问题应该是这样的一个流程:

1.能否用单线程解决?(单线程本身就是线程安全的)

2.我开发的多线程业务是否线程安全?

线程安全是保证程序正常运行的关键,所以应该把线程安全作为开发多线程对于考虑的首要问题

 

最后说两句:

本文所以代码都更新到我的github中,大家可以去clone或者Fork,我会持续更新的。

点击这里进入我的Github
喜欢的朋友可以点击下方的推荐,或者写个评论我们共同探讨Java高并发!!!

 

 

 

 

 

个人博客网站 http://www.janti.cn
相关文章
|
1月前
|
JSON 网络协议 安全
【Java】(10)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
129 1
|
1月前
|
JSON 网络协议 安全
【Java基础】(1)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
147 1
|
2月前
|
Java
Java 数组学习笔记
本文整理Java数组常用操作:遍历、求和、查找、最值及二维数组行求和等典型练习,涵盖静态初始化、元素翻倍、去极值求平均等实例,帮助掌握数组基础与应用。
|
2月前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
|
2月前
|
小程序 Java 知识图谱
Java 学习笔记 —— BMI & BMR 计算器
这是一个使用 Java 编写的 BMI 与 BMR 计算器小程序,可输入年龄、性别、身高和体重,计算身体质量指数(BMI)和基础代谢率(BMR),并输出健康评估结果。通过该项目,掌握了 Java 的输入处理、数据验证、条件判断、数学运算及格式化输出等基础知识,是 Java 初学者的理想练习项目。
Java 数据库 Spring
129 0
|
2月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
207 16
|
3月前
|
缓存 并行计算 安全
关于Java多线程详解
本文深入讲解Java多线程编程,涵盖基础概念、线程创建与管理、同步机制、并发工具类、线程池、线程安全集合、实战案例及常见问题解决方案,助你掌握高性能并发编程技巧,应对多线程开发中的挑战。
|
3月前
|
数据采集 存储 前端开发
Java爬虫性能优化:多线程抓取JSP动态数据实践
Java爬虫性能优化:多线程抓取JSP动态数据实践
|
4月前
|
缓存 NoSQL Java
Java 项目实操高并发电商系统核心模块实现从基础到进阶的长尾技术要点详解 Java 项目实操
本项目实战实现高并发电商系统核心模块,涵盖商品、订单与库存服务。采用Spring Boot 3、Redis 7、RabbitMQ等最新技术栈,通过秒杀场景解决库存超卖、限流熔断及分布式事务难题。结合多级缓存优化查询性能,提升系统稳定性与吞吐能力,适用于Java微服务开发进阶学习。
153 0