Java进行多线程编程?(lambda表达式~)

简介: Java进行多线程编程?(lambda表达式~)

本文标题:Java进行多线程编程?那么,Java为啥不学学如何进程多进程编程呢??原因在于:Java圈子中不提倡多进程编程~~

接下来,我们来写一个最为基础/入门的HelloWord程序来感受如何进行多线程~~

Java标准库提供了一个类Thread能够表示一个线程~

public class MyThread extends Thread {
    //继承:创建一个类MyThread,继承标准库的Thread
    @Override
    public void run(){//重写,子类重写父类的方法
        System.out.println("Hello Word");
    }
    public static void main(String[] args) {
        //先创建MyThread实列,t的引用实际上是指向子类的实列
        Thread t=new MyThread();
        //启动线程,再进程中搞了另外一个流水线,新的流水线开始并发的执行另外一个逻辑了~
        t.start();
    }
}

在上述的代码段中,主要涉及到两个线程:

  1. main方法所对应的线程(一个进程中至少得有一个线程),也可也称为主线程;
  2. 通过t.start()创建的新的线程

通过右键运行main方法,其实是idea对应的进程,创建了一个新的Java进程,这个Java进程来执行咱们自己写的代码,这个Java进程里就有两个线程,一个是main线程,另一个是t线程~

调整代码,具体仔细看一下,体会一下:“每个线程都是一个独立的执行流~”;

public class MyThread extends Thread {
    //继承:创建一个类MyThread,继承标准库的Thread
    @Override
    public void run(){//重写,子类重写父类的方法
//        System.out.println("Hello Word");
        //死循环
        while (true){
            System.out.println("hello  t ---->t线程");
        }
    }
    public static void main(String[] args) {
        //先创建MyThread实列,t的引用实际上是指向子类的实列
        Thread t=new MyThread();
        //启动线程,再进程中搞了另外一个流水线,新的流水线开始并发的执行另外一个逻辑了~
        t.start();
        //死循环
        while (true){
            System.out.println("hello  main  ---->main线程");
        }
    }
}

在上述的代码中,t线程和main线程都写了一个while(true)的死循环,按道理来说,一进入while(true)就会死循环了,但是,实际的代码运行情况却不是这样的~~

截取自运行结果部分示意图~

观看运行结果,显而易见的可以得到:交替打印~,此时看到的效果:hello  t ---->t线程和hello  main  ---->main线程都能打印出来,通过t.start()另外启动了一个执行流,而新的执行流(新的线程)来执行        while (true){System.out.println("hello  t ---->t线程"); },因此这段代码与        while (true){System.out.println("hello  main  ---->main线程"); }看起来在同时执行;

线程是能够交替运行的,但是打印出来的结果肯定是有先后的!!因为两个线程往同样一个控制台上控制,同一个控制台必须得顺序输出~!

通过上述代码的运行结果,我们可以看到这两个线程就算再同时执行,先打印几个hello  t ---->t线程,再打印几个hello  main  ---->main线程…………,如果是单个线程的话,此时就是只能打印其中一个,看不到另外一个!

当然,我们对上述代码的main方法做出简单更改!

public class MyThread extends Thread {
    //继承:创建一个类MyThread,继承标准库的Thread
    @Override
    public void run(){//重写,子类重写父类的方法
//        System.out.println("Hello Word");
        //死循环
        while (true){
            System.out.println("hello  t ---->t线程");
        }
    }
    public static void main(String[] args) {
        //先创建MyThread实列,t的引用实际上是指向子类的实列
        Thread t=new MyThread();
        //启动线程,再进程中搞了另外一个流水线,新的流水线开始并发的执行另外一个逻辑了~
        //start()会创建新的线程
        //t.start();
        //run不好创建新的线程,run是在main线程中执行的
        t.run();
        //死循环
        while (true){
            System.out.println("hello  main  ---->main线程");
        }
    }
}

代码的运行结果为:

此处,代码没有创建其他的线程,两个死循环都在同一个线程中,执行到第一个死循环后,代码就出不来了,第二个死循环就进不去了,因此,代码会一直在打印:hello  t ---->t线程

在MyThread中:

public class MyThread extends Thread {
    //继承:创建一个类MyThread,继承标准库的Thread
    @Override
    public void run(){//重写,子类重写父类的方法
//        System.out.println("Hello Word");
        //死循环
        while (true){
            System.out.println("hello  t ---->t线程");
        }
    }
}

run()方法:线程的入口方法;

run()方法不是一个随便的方法,是重写了父类的方法~

这种重写一般就是:功能的扩展

一般这样的重写方法是不需要咱们自己手动调用的,已经有其他代码来调用了~如果我们随便写了run2()方法,这样的方法没有在t.start()中被调用,是无法自动执行的~

t.start()方法:调用操作系统的API,创建新的线程,从而新的线程里调用t.run()方法

上述的代码打印太快,不利于查看,可以加thread.sleep(1000),1000是指1000毫秒等于1秒

sleep是Thread的静态方法(通过类名调用)。(报错的话,抛出异常即可)

当然,sleep(1000)仅之休眠一秒,之后的打印结果也不是严格意义上的交替,每一秒过后,是先打印main线程,还是先打印t线程,都是不确定的,因为多个线程在CPU上调度执行的顺序是不确定的(随机);

线程虽然有优先级,但是,这个优先级对于系统来说,只是“建议”

program---->jdk---->bin---->jconsloe.exe应用程序,使用这个jdk提供的工具,就能够给我们查看出Java进程里的线程详情~~

jconsloe只能分析Java进程,不能识别非Java进程,主注意:idea是用Java写的,jconsloe也是用Java写的(占用两个进程,需要注意区分-----》看名字)

当然,有的同学运行jconsloe发现进程列表是空的,大概率是权限问题,右键----》以管理员方式运行即可~(确保代码在运行中,才能看到~)

上述的代码是:使用继承Thread,重写run()方法的方式来创建线程(使用Thread的run()描述线程的入口)

接下来,我们使用实现Runnable,通过重写run方法的方式来创建线程(使用Runnable的interface来描述线程的入口~)

public class MyRunnable implements Runnable{
    @Override
    public void run() {
        while (true){
            System.out.println("hello t---->t线程");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) throws InterruptedException {
        MyRunnable runnable=new MyRunnable();
        Thread t=new Thread(runnable);
        t.start();
        while (true){
            System.out.println("hello main");
            Thread.sleep(1000);
        }
    }
}

对于上述代码的运行结果,大家可自行尝试(交替打印)

3.继承Thread,使用匿名内部类(内部类:定义在类里面的类)

public class Main1 {
    public static void main(String[] args) throws InterruptedException {
        Thread t=new Thread(){
            @Override
            public void run(){
                while (true){
                    System.out.println("hello t---->t线程");
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };
        t.start();
        while (true){
            System.out.println("hello main---->main线程");
            Thread.sleep(1000);
        }
    }
}

4.实现Runnable使用匿名内部类

public class Main1 {
    public static void main(String[] args) throws InterruptedException {
        Thread t=new Thread(){
            @Override
            public void run(){
                while (true){
                    System.out.println("hello t---->t线程");
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };
        t.start();
        while (true){
            System.out.println("hello main---->main线程");
            Thread.sleep(1000);
        }
    }
}

需要注意的是:{ }放到哪里,就算针对哪个类创建的匿名内部类

当然,创建线程最推荐的写法:使用lambda表达式!!最简单最直观的写法(前面几种可以不记)

lambda表达式:本质就是一个匿名函数!!(没有名字的函数,这种一般是一次性的),Java里面函数(方法)是无法脱离类的,在Java里面lambda就相当于一个列外!!

lambda表达式的基本写法:()->{ }

()小括号里面放参数,如果只有一个参数()可省略

{ }大括号里面放函数,写各种Java代码,如果只有一行代码,{ }可省略

那么,我们来看一下具体的写法吧~

public class ThreadDemos {
    public static void main(String[] args) throws InterruptedException {
        Thread t=new Thread(()->{
            while (true){
                System.out.println("hello t---->t线程");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        t.start();
        while (true){
            System.out.println("hello main---->main线程");
            Thread.sleep(1000);
        }
    }
}

上述的代码即为lambda表达式的写法(强调~)

更多关于lambda表达式的资料,请详见:百度安全验证

相关文章
|
3天前
|
存储 缓存 Java
Java 并发编程——volatile 关键字解析
本文介绍了Java线程中的`volatile`关键字及其与`synchronized`锁的区别。`volatile`保证了变量的可见性和一定的有序性,但不能保证原子性。它通过内存屏障实现,避免指令重排序,确保线程间数据一致。相比`synchronized`,`volatile`性能更优,适用于简单状态标记和某些特定场景,如单例模式中的双重检查锁定。文中还解释了Java内存模型的基本概念,包括主内存、工作内存及并发编程中的原子性、可见性和有序性。
Java 并发编程——volatile 关键字解析
|
1天前
|
Java
Java—多线程实现生产消费者
本文介绍了多线程实现生产消费者模式的三个版本。Version1包含四个类:`Producer`(生产者)、`Consumer`(消费者)、`Resource`(公共资源)和`TestMain`(测试类)。通过`synchronized`和`wait/notify`机制控制线程同步,但存在多个生产者或消费者时可能出现多次生产和消费的问题。 Version2将`if`改为`while`,解决了多次生产和消费的问题,但仍可能因`notify()`随机唤醒线程而导致死锁。因此,引入了`notifyAll()`来唤醒所有等待线程,但这会带来性能问题。
Java—多线程实现生产消费者
|
3天前
|
安全 Java Kotlin
Java多线程——synchronized、volatile 保障可见性
Java多线程中,`synchronized` 和 `volatile` 关键字用于保障可见性。`synchronized` 保证原子性、可见性和有序性,通过锁机制确保线程安全;`volatile` 仅保证可见性和有序性,不保证原子性。代码示例展示了如何使用 `synchronized` 和 `volatile` 解决主线程无法感知子线程修改共享变量的问题。总结:`volatile` 确保不同线程对共享变量操作的可见性,使一个线程修改后,其他线程能立即看到最新值。
|
3天前
|
消息中间件 缓存 安全
Java多线程是什么
Java多线程简介:本文介绍了Java中常见的线程池类型,包括`newCachedThreadPool`(适用于短期异步任务)、`newFixedThreadPool`(适用于固定数量的长期任务)、`newScheduledThreadPool`(支持定时和周期性任务)以及`newSingleThreadExecutor`(保证任务顺序执行)。同时,文章还讲解了Java中的锁机制,如`synchronized`关键字、CAS操作及其实现方式,并详细描述了可重入锁`ReentrantLock`和读写锁`ReadWriteLock`的工作原理与应用场景。
|
3天前
|
NoSQL Redis
单线程传奇Redis,为何引入多线程?
Redis 4.0 引入多线程支持,主要用于后台对象删除、处理阻塞命令和网络 I/O 等操作,以提高并发性和性能。尽管如此,Redis 仍保留单线程执行模型处理客户端请求,确保高效性和简单性。多线程仅用于优化后台任务,如异步删除过期对象和分担读写操作,从而提升整体性能。
14 1
|
2月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
60 1
|
2月前
|
Java 开发者
在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱,帮助你更好地理解和选择适合项目需求的线程创建方式。
32 3
|
2月前
|
Java 开发者
在Java多线程编程中,选择合适的线程创建方法至关重要
【10月更文挑战第20天】在Java多线程编程中,选择合适的线程创建方法至关重要。本文通过案例分析,探讨了继承Thread类和实现Runnable接口两种方法的优缺点及适用场景,帮助开发者做出明智的选择。
25 2
|
2月前
|
Java
Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口
【10月更文挑战第20天】《JAVA多线程深度解析:线程的创建之路》介绍了Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口。文章详细讲解了每种方式的实现方法、优缺点及适用场景,帮助读者更好地理解和掌握多线程编程技术,为复杂任务的高效处理奠定基础。
41 2
|
2月前
|
Java 开发者
Java多线程初学者指南:介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点
【10月更文挑战第20天】Java多线程初学者指南:介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点,重点解析为何实现Runnable接口更具灵活性、资源共享及易于管理的优势。
47 1