JAVA网络编程线程

作者：晏圣玲 | 来源：互联网 | 2023-07-20 12:39

运行线程创建Thread的子类publicclassThreadChildextendsThread{@Overridepublicvoidrun(){while(true){Sy

运行线程

创建Thread的子类

public class ThreadChild extends Thread {
    @Override
    public void run() {
        while (true) {
            System.out.println("run");
        }
    }
}

public class Test {
    public static void main(String[] args) throws Exception {
        ThreadChild t = new ThreadChild();
        t.start();
    }
}

创建Thread传入Runnable接口实现类

public class RunnableImpl implements Runnable {
    @Override
    public void run() {
        while (true) {
            System.out.println("run");
        }
    }
}

public class Test {
    public static void main(String[] args) throws Exception {
        Thread t = new Thread(new RunnableImpl());
        t.start();
    }
}

回调

ExecutorService线程池的Submit()可接收Runnable或者Callable.Callable执行结束后有返回值,Runnable执行结束后没有返回值.可以通过submit的返回对象Future的get方法获取返回返回值,需要注意的是get方法是一个阻塞方法.若线程没有执行完毕,则会阻塞get()直到线程执行结束后返回数据.

public static void main(String[] args) throws Exception {
        ExecutorService executorService = Executors.newFixedThreadPool(10);

        Future future = executorService.submit(() -> {
            TimeUnit.SECONDS.sleep( 3);
            return 1;
        });
        Future future2 = executorService.submit(() -> {
        });

        Future future3 = executorService.submit(() -> {
        }, "aaa");

        System.out.println(future.get());
        System.out.println(future2.get());
        System.out.println(future3.get());
    }

同步方法

synchronized关键字和方法组合使用后，该方法是一个同步方法。同步方法都有一个隐试的锁，多个线程同时执行该方法时，只能顺序执行，未强到锁的线程处于阻塞状态。另外静态方法和非静态方法使用的是不同的锁，非静态方法的锁是对象锁，若两个线程通过两个该类的对象调用那么互不影响。静态方法是类锁，即本类的Class对象。同步方法无法指定锁资源，要么是this锁，要么是Class锁。

public class Test {
    public static void main(String[] args) throws Exception {
        Test test = new Test();
        
        Thread t1 = new Thread(()->{
            test.synFunction();
        });
        
        Thread t2 = new Thread(()->{
            test.synFunction();
        });
        
        t1.start();
        t2.start();
    }
    
    public synchronized void synFunction(){
        try {
            System.out.println("-------------");
            TimeUnit.SECONDS.sleep(3);
        }catch (Exception e) {}        
    }
}

public class Test {
    public static void main(String[] args) throws Exception {
        
        Thread t1 = new Thread(()->{
            Test.synFunction();
        });
        
        Thread t2 = new Thread(()->{
            Test.synFunction();
        });
        
        t1.start();
        t2.start();
    }
    
    public static synchronized void synFunction(){
        try {
            System.out.println("-------------");
            TimeUnit.SECONDS.sleep(3);
        }catch (Exception e) {}        
    }
}

同步块

同步代码块可以指定锁对象，非静态方法可以指定任意的对象锁，或者任意的类锁。但静态方法只能使用任意的类锁。

public class Test {
    public static void main(String[] args) throws Exception {
        Test lock = new Test();
        
        Thread t1 = new Thread(() -> {
            lock.synFunction();
        });

        Thread t2 = new Thread(() -> {
            lock.synFunction();
        });

        t1.start();
        t2.start();
    }

    public void synFunction() {
        synchronized (this) {//对象锁
            try {
                System.out.println("-------------");
                TimeUnit.SECONDS.sleep(3);
            } catch (Exception e) {
            }
        }
    }
}

public class Test {
    public static void main(String[] args) throws Exception {
        Test lock1 = new Test();
        Test lock2 = new Test();
        
        Thread t1 = new Thread(() -> {
            lock1.synFunction(lock1);
        });

        Thread t2 = new Thread(() -> {
            lock2.synFunction(lock2);
        });

        t1.start();
        t2.start();
    }

    public void synFunction(Object lock) {
        synchronized (lock) {//对象锁
            try {
                System.out.println("-------------");
                TimeUnit.SECONDS.sleep(3);
            } catch (Exception e) {
            }
        }
    }
}

public class Test {
    public static void main(String[] args) throws Exception {
        Test lock1 = new Test();
        Test lock2 = new Test();
        
        Thread t1 = new Thread(() -> {
            lock1.synFunction();
        });

        Thread t2 = new Thread(() -> {
            lock2.synFunction();
        });

        t1.start();
        t2.start();
    }

    public void synFunction() {
        synchronized (Test.class) {//类锁
            try {
                System.out.println("-------------");
                TimeUnit.SECONDS.sleep(3);
            } catch (Exception e) {
            }
        }
    }
}

public class Test {
    public static void main(String[] args) throws Exception {
        
        Thread t1 = new Thread(() -> {
            Test.synFunction();
        });

        Thread t2 = new Thread(() -> {
            Test.synFunction();
        });

        t1.start();
        t2.start();
    }

    public static void synFunction() {
        synchronized (Object.class) {//类锁
            try {
                System.out.println("-------------");
                TimeUnit.SECONDS.sleep(3);
            } catch (Exception e) {
            }
        }
    }
}

死锁

当多个线程竞争锁时，可能会导致死锁。一个线程由于没有得到一个锁而阻塞它也不会释放已经获取的锁。方法1获取锁的顺序是Test.class,Object.class。方法2获取锁的顺序是Object.class，Test.class。程序会陷入死锁。

public class Test {
    public static void main(String[] args) throws Exception {

        Thread t1 = new Thread(() -> {
            Test.synFunction1();
        });

        Thread t2 = new Thread(() -> {
             Test.synFunction2();
        });

        t1.start();
        t2.start();
    }

    public static void synFunction1() {
        synchronized (Test.class) {// 类锁
            try {
                System.out.println("synFunction1-------------AAAAAAAAAAAAA");
                synchronized (Object.class) {// 类锁
                    try {
                        System.out.println("synFunction1-------------bbbbbbbbbbbbb");
                    } catch (Exception e) {
                    }
                }
            } catch (Exception e) {
            }
        }    
    }

    public static void synFunction2() {
        synchronized (Object.class) {// 类锁
            try {
                System.out.println("synFunction2-------------AAAAAAAAAAAAA");
            } catch (Exception e) {
            }
            synchronized (Test.class) {// 类锁
                try {
                    System.out.println("synFunction2-------------bbbbbbbbbbbbb");
                } catch (Exception e) {
                }
            }
        }
    }
}

优先级

不是所有线程创建时都是均等的，每个线程都有一个优先级，指定从0-10的整数。当多个线程运行时，虚拟机通常只运行最高优先级的线程，但这并不是一个严格的规则。在Java中10是最高优先级，0是最低优先级。默认优先级为5.并不是所有操作系统都支持这11个优先级。例如Windows只有7个优先级。优先级（1，2）（3，4）（6，7）（8，9）会做同样的处理。

public class Test {
    public static void main(String[] args) throws Exception {

        Thread t1 = new Thread(() -> {
            Test.synFunction("aaaaaaaaaaa");
        });

        Thread t2 = new Thread(() -> {
             Test.synFunction("bbbbbbbbbb");
        });

        t2.setPriority(9);
        t1.setPriority(1);
        
        t1.start();
        t2.start();
    }

    public static void synFunction(String name) {
        System.out.println(name+"--------------");
    }

}

暂停

为了能让其他线程有机会运行，一个线程有8中方式可以暂停或者指示它准备暂停。

可以对IO阻塞

要让网络程序中的线程自动放弃CPU控制权，最常见的方式是IO阻塞。由于CPU比网络和磁盘快的多，网络程序经常会在等待数据从网络到达或向网络发送数据时阻塞。即使只阻塞几毫秒，这一点时间也足够其他线程用来完成重要的任务。

可以对同步对象阻塞

线程在进入一个同步方法或代码块时也会阻塞。如果这个线程没有所同步对象的锁，而其他线程拥有这个锁，这个线程就会暂停，直到锁被释放为止。如果这个锁永远不会释放，那么这个线程会永久停止。

可以放弃

调用Thread.yield()静态方法可以做到显试的放弃线程控制权，这将通知虚拟机，可以优先执行其他线程。放弃并不会释放这个线程拥有的锁，因此在理想情况下被放弃的线程不要做任何的同步。如果等待运行的其他线程都是因为这个线程所拥有的同步资源而阻塞，那么这些线程将不能运行。实际上，控制权将回到唯一可以运行的线程，即刚刚放弃的这个线程，这很大程度上失去了放弃的意义。

public class Test {
    public static void main(String[] args) throws Exception {

        Thread t1 = new Thread(() -> {
            Test.synFunction("aaaaaaaaaaa");
        });

        Thread t2 = new Thread(() -> {
            Test.synFunction2("bbbbbbbbbb");
        });

        t1.start();
        t2.start();
    }

    public static void synFunction(String name) {
        for (int i = 0;; i++) {
            Thread.yield();
            System.out.println(name + "--------------" + i);
        }
    }

    public static void synFunction2(String name) {
        for (int i = 0;; i++)
            System.out.println(name + "--------------"+i);
    }

}

可以休眠

休眠是更有利的放弃方式。放弃只是表示线程愿意暂停，让其他有相同优先级的线程有机会运行，而进入休眠的线程有所不同，不管有没有其他线程准备运行，休眠线程都会暂停。这样一来，不只是其他有相同优先级的线程会得到机会，还会给较低优先级的线程运行机会。不过进入休眠的线程仍然拥有它已经获得得所有锁。因此其他需要相同锁得线程依然会阻塞，要避免在同步方法或块内让线程休眠。

public class Test {
    public static void main(String[] args) throws Exception {

        Thread t1 = new Thread(() -> {
            Test.synFunction("aaaaaaaaaaa");
        });

        Thread t2 = new Thread(() -> {
            Test.synFunction2("bbbbbbbbbb");
        });

        t1.start();
        t2.start();
    }

    public synchronized static void synFunction(String name) {
        try {
            System.out.println(name);
            Thread.sleep(1000 * 10);
        } catch (Exception e) {
        }

    }

    public synchronized static void synFunction2(String name) {
        System.out.println(name);
    }
}

package com.datang.bingxiang.demo;

import java.util.concurrent.TimeUnit;

public class Test {
    public static void main(String[] args) throws Exception {

        Thread t1 = new Thread(() -> {
            Test.synFunction("aaaaaaaaaaa");
        });

        Thread t2 = new Thread(() -> {
            Test.synFunction2("bbbbbbbbbb");
        });

        t1.start();
        t2.start();
    }

    public synchronized static void synFunction(String name) {
        try {
            System.out.println(name);
            Thread.sleep(1000 * 3, 999999);//3000毫秒+999999毫秒（第二个参数不能超过999999，也就是不能超过1毫秒）
        } catch (Exception e) {
            System.out.println(e);
        }

    }

    public synchronized static void synFunction2(String name) {
        System.out.println(name);
    }
}

可以连接另一个线程

连接线程(既调用join()方法得线程A)等待被连接的线程(join()方法所属的线程对象B)执行完毕后才会执行。在A线程调用B线程的join()A线程会等待B线程执行结束后才会继续执行。要注意的是A线程并不会释放已经获取的锁资源。

public class Test {
    public static void main(String[] args) throws Exception {
        
        Thread t2 = new Thread(() -> {
            Test.synFunction2("bbbbbbbbbb");
        });

        Thread t1 = new Thread(() -> {
            Test.synFunction("aaaaaaaaaaa",t2);
        });

        
        t1.start();
        t2.start();
    }

    public  static void synFunction(String name,Thread t) {
        try {
            t.join();
            //t.join(1000);
            //t.join(1000,999999);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        for (int i = 0; i <5; i++) {
            System.out.println(name);
        }
    }

    public  static void synFunction2(String name) {
        try {
            Thread.sleep(1000*3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        for (int i = 0; i <5; i++) {
            System.out.println(name);
        }
    }
}

可以等待一个对象

线程可以等待一个它锁定的对象.在等待时,它会释放这个对象的锁并暂停,直到它得到其他线程的通知.另一个线程以某种方式修改这个对象,通知等待对象的线程,然后继续执行.等待会暂停执行,直到一个对象或资源到达某种状态.实际上,要等待某个特定的对象,希望暂停的线程首先必须使用synchronized获得这个对象的锁,然后调用这个对象的三个重载wait()方法之一.

public class Demo {
    public static void main(String[] args) throws Exception {
        Demo d = new Demo();
        Thread t1 = new Thread(() -> {
            d.a();
        });
        Thread t2 = new Thread(() -> {
            d.b();
        });
        t1.start();
        t2.start();
    }

    boolean flag = true;

    public synchronized void a() {
        try {
            while (true) {
                if (flag) {
                    System.out.println("执行AAAAAAAAAAA");
                    flag = false;
                } else {
                    wait();//等待,不限制等待时间
                    //wait(1000);//等待指定的时间,没有被notify唤醒也可以自己退出等待
                    //wait(1000,999999);//毫秒+纳秒的等待时间
                }
                notify();
            }
        } catch (Exception e) {
        }
    }

    public synchronized void b() {
        try {
            while (true) {
                if (!flag) {
                    System.out.println("执行BBBBBBBBBBB");
                    flag = true;
                } else {
                    wait();
                }
                notify();
            }
        } catch (Exception e) {
        }
    }
}

可以结束

线程要以合理的方式放弃CPU控制权,一种方式是结束.当run()方法返回线程时,线程将撤销,其他线程可以接管CPU.在网络应用程序中,包装一个阻塞操作的线程往往会这么做,例如线程从服务器下载一个文件,这样应用程序的其他部分就不会被阻塞.另一方面,如果run()方法太简单,总是很快结束,而不会紫色,那就存在一个很实际的问题:到底有没有必要生成一个线程.虚拟机在建立和撤销线程时会有很大的开销.如果线程会在极端的时间内结束,那么使用一次简单的方法调用而不是单独的线程可能会结束的更快.

可以被更高优先级线程抢占

Thread的setPriority(int priority)设置线程的优先级.

推荐阅读

jsp
OC学习笔记之@property和@synthesize

本文介绍了OC学习笔记中的@property和@synthesize，包括属性的定义和合成的使用方法。通过示例代码详细讲解了@property和@synthesize的作用和用法。 ... [详细]

蜡笔小新 2023-12-14 12:05:06
int
在类中定义数组时出错 - Error on defining arrays in class

Iamtryingtomakeaclassthatwillreadatextfileofnamesintoanarray,thenreturnthatarra ... [详细]

蜡笔小新 2023-12-14 17:38:12
default
阿里云物联网 .NET Core 客户端 | CZGL.AliIoTClient：4. 设备上报属性

阿,里,云,物,联网,net,core,客户端,czgl,aliiotclient, ... [详细]

蜡笔小新 2023-12-14 12:40:20
int
Golang如何使用Cookie跟踪位置

关键词：Golang, Cookie, 跟踪位置, net/http/cookiejar, package main, golang.org/x/net/publicsuffix, io/ioutil, log, net/http, net/http/cookiejar ... [详细]

蜡笔小新 2023-12-13 15:47:22
get
java命令运行

Java在运行已编译完成的类时，是通过java虚拟机来装载和执行的，java虚拟机通过操作系统命令JAVA_HOMEbinjava–option来启 ... [详细]

蜡笔小新 2023-12-12 19:26:55
int
Java太阳系小游戏分析和源码详解

本文介绍了一个基于Java的太阳系小游戏的分析和源码详解。通过对面向对象的知识的学习和实践，作者实现了太阳系各行星绕太阳转的效果。文章详细介绍了游戏的设计思路和源码结构，包括工具类、常量、图片加载、面板等。通过这个小游戏的制作，读者可以巩固和应用所学的知识，如类的继承、方法的重载与重写、多态和封装等。 ... [详细]

蜡笔小新 2023-12-14 19:53:34
import
YOLOv7基于自己的数据集从零构建模型完整训练、推理计算超详细教程

本文介绍了关于人工智能、神经网络和深度学习的知识点，并提供了YOLOv7基于自己的数据集从零构建模型完整训练、推理计算的详细教程。文章还提到了郑州最低生活保障的话题。对于从事目标检测任务的人来说，YOLO是一个熟悉的模型。文章还提到了yolov4和yolov6的相关内容，以及选择模型的优化思路。 ... [详细]

蜡笔小新 2023-12-14 18:28:01
int
GetWindowLong函数

今天在看一个代码里头写了GetWindowLong(hwnd,0)，我当时就有点费解，靠，上网搜索函数原型说明，死活找不到第 ... [详细]

蜡笔小新 2023-12-14 17:58:15
int
C#学习教程：在Console中工作但在Windows窗体中不工作的异步代码分享

本文分享了一个关于在C#中使用异步代码的问题，作者在控制台中运行时代码正常工作，但在Windows窗体中却无法正常工作。作者尝试搜索局域网上的主机，但在窗体中计数器没有减少。文章提供了相关的代码和解决思路。 ... [详细]

蜡笔小新 2023-12-14 15:56:00
select
实现下拉列表，点击其他位置自动隐藏效果的三种方式比较

目录实现效果：实现环境实现方法一：基本思路主要代码JavaScript代码总结方法二主要代码总结方法三基本思路主要代码JavaScriptHTML总结实 ... [详细]

蜡笔小新 2023-12-14 15:03:14
int
Java容器中的compareto方法排序原理解析

本文从源码解析Java容器中的compareto方法的排序原理，讲解了在使用数组存储数据时的限制以及存储效率的问题。同时提到了Redis的五大数据结构和list、set等知识点，回忆了作者大学时代的Java学习经历。文章以作者做的思维导图作为目录，展示了整个讲解过程。 ... [详细]

蜡笔小新 2023-12-14 13:53:31
select
关于cuowu类的错误提示和使用AdjustmentListener的问题

本文讨论了一个关于cuowu类的问题，作者在使用cuowu类时遇到了错误提示和使用AdjustmentListener的问题。文章提供了16个解决方案，并给出了两个可能导致错误的原因。 ... [详细]

蜡笔小新 2023-12-13 22:09:56
jsp
Linux进程控制块PCBtask_struct结构体结构及作用详解

本文详细介绍了Linux中进程控制块PCBtask_struct结构体的结构和作用，包括进程状态、进程号、待处理信号、进程地址空间、调度标志、锁深度、基本时间片、调度策略以及内存管理信息等方面的内容。阅读本文可以更加深入地了解Linux进程管理的原理和机制。 ... [详细]

蜡笔小新 2023-12-13 21:31:18
jsp
CentOS 7部署KVM虚拟化环境之一架构介绍

本文介绍了CentOS 7部署KVM虚拟化环境的架构，详细解释了虚拟化技术的概念和原理，包括全虚拟化和半虚拟化。同时介绍了虚拟机的概念和虚拟化软件的作用。 ... [详细]

蜡笔小新 2023-12-12 21:38:57
select
【openwrt】设备mt7628关于wan侧eth0.1 mac地址固定的问题

本文讨论了在openwrt-17.01版本中，mt7628设备上初始化启动时eth0的mac地址总是随机生成的问题。每次随机生成的eth0的mac地址都会写到/sys/class/net/eth0/address目录下，而openwrt-17.01原版的SDK会根据随机生成的eth0的mac地址再生成eth0.1、eth0.2等，生成后的mac地址会保存在/etc/config/network下。 ... [详细]

蜡笔小新 2023-12-12 17:47:48

晏圣玲

这个家伙很懒，什么也没留下！

Tags | 热门标签

RankList | 热门文章