新手场景Java线程相关问题及解决方案

一、创建线程方式

a. 继承线程类( new Thread),重写run方法;

public class MyThread extends Thread{//继承Thread类
  public void run(){
  //重写run方法
  }
}
public class Main {
public static void main(String[] args){
    new MyThread().start();//创建并启动线程
  }
}

b. 实现runnable接口,将runnable对象传入Thread类;

public class MyThread2 implements Runnable {//实现Runnable接口
  public void run(){
  //重写run方法
  }
}
public class Main {
  public static void main(String[] args){
    //创建并启动线程
    MyThread2 myThread=new MyThread2();
    Thread thread=new Thread(myThread);
    thread().start();
    //或者  new Thread(new MyThread2()).start();
  }
}

c. 使用线程池的方式,提交runnable或callable任务;

public class Main {
  public static void main(String[] args){
   MyThread3 th=new MyThread3();
   //使用Lambda表达式创建Callable对象
   //使用FutureTask类来包装Callable对象
   FutureTask<Integer> future=new FutureTask<Integer>(
    (Callable<Integer>)()->{
      return 5;
    }
   );
   new Thread(task,"有返回值的线程").start();//实质上还是以Callable对象来创建并启动线程
   try{
    System.out.println("子线程的返回值:"+future.get());//get()方法会阻塞,直到子线程执行结束才返回
   }catch(Exception e){
    ex.printStackTrace();
   }
  }
}

d. 推荐使用第三种方式。高效,资源可控;

二、什么是线程同步?线程同步什么时候用?

1)什么是线程同步;

即当有一个线程在对内存进行操作时,其他线程都不可以对这个内存地址进行操作,直到该线程完成操作, 其他线程才能对该内存地址进行操作,而其他线程又处于等待状态;

2)线程同步在什么时候用(卖火车票,飞机票,取钱);

简单的说,同步就是防止多个线程访问同一个对象,造成数据不安全;线程的同步意味安全,譬如你去取钱 ,你的执行语句和我用的要是相同对象 ,你要在卡上扣除的钱数和银行卡里面要有这么多钱才能扣除;

三、什么是线程安全;

1)所谓线程安全,是多个线程并发执行的情况下结果总是跟单线程运行的结果一致,逻辑上不会出现错误;

2)什么情况下会出现线程安全问题?

多个线程同时操作同一份数据,常常会导致线程安全问题。比如:全局的变量,静态变量,同一条数据的数据库操作等;

局部变量,通常不会存在线程安全问题。

3)常见的解决线程安全的方式:

1)避免使用全局的变量,将全局的变量定义为局部变量。

2)加同步锁,使得线程同步。

a. Synchronized 同步关键字,可以加在方法和代码块上面;

/**
   * synchronized添加到方法上面,使方法变成同步方法
   * 如果是静态方法,锁住的是class
   * 如果是普通方法,锁住的this,当前对象 synchronized(this)
   * 多个线程锁住的对象是同一个对象才能够同步,每个类都有当前对象
   */

  public static synchronized void salTicket(){
    if (ticketNum > 0) {
      try {
        Thread.sleep(100);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println(Thread.currentThread().getName() + "买到第" + ticketNum-- + "张票");
      System.out.println(Thread.currentThread().getName() + "买票完成");
    }else {
      System.out.println("票已经售完,"+Thread.currentThread().getName() + "未买到票");
    }
  }

b. 多个线程方法是否同步,需要判断多个线程是否共用同一把锁;

/**
   * 同步代码块
   */
  public void salTicket2() {
    synchronized (this) {
      //()中指定锁对象,this表示当前对象,多个线程使用同一个对象调用该方法时,是同步的
      //如果指定为 class,则该类的任意对象调用该方法都是同步的
      if (ticketNum > 0) {
        try {
          Thread.sleep(100);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "买到第" + ticketNum-- + "张票");
        System.out.println(Thread.currentThread().getName() + "买票完成");
      } else {
        System.out.println("票已经售完," + Thread.currentThread().getName() + "未买到票");
      }
    }
  }

c. ReentrantLock 对象的lock 方法进行加锁,unLock进行解锁。Unlock必须放在finally中。确保能够最终释放锁;

//锁对象 private static ReentrantLock lock=new ReentrantLock();
 /**
   * 使用lock对象进行同步,多个线程使用的是同一个lock对象,才会是同步的
   */
  public void salTicket3() {
    lock.lock();//加锁
      if (ticketNum > 0) {
        try {
          Thread.sleep(100);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }finally {
          lock.unlock();//释放锁,必须放在finally代码块中,以确保能够释放锁
        }
        System.out.println(Thread.currentThread().getName() + "买到第" + ticketNum-- + "张票");
        System.out.println(Thread.currentThread().getName() + "买票完成");
      } else {
        System.out.println("票已经售完," + Thread.currentThread().getName() + "未买到票");
      }
  }

3)数据库操作的话,也可以使用乐观锁或悲观锁的方式

4)Springmvc是如何解决线程安全问题的?

Springmvc的数据接收和传递都是方法级别的,使用局部变量来接收和传递,所以不存在线程安全问题。

四、Wait 和notify

线程间通讯的一种机制。用于手动控制线程之间的切换。在同步代码中的锁对象调用。可以同时通过共享内存对象,来实现数据的传递;

  • Wait 使线程进入阻塞状态,并释放锁资源;
  • Notify 随机唤醒一个因wait进入阻塞状态的线程;
  • NotifyALL 唤醒所有的因wait进入阻塞状态的线程;

3)多线程实现,怎么用?

a、将单个大的任务拆分成多个小任务,使用多线程去执行;

多线程的效率不一定比单线程的效率高;

通过线程池创建线程,通过实现runnable(无返回值)或callable(有返回值)接口来定义任务;

通过线程池的submit invoke invokeAll 等方法来执行任务;

b、使用线程异步完成某些任务,提高并发响应的能力,或让线程周期性的执行某些任务;

c、四种线程池的特点及其创建;

Java通过Executors提供四种线程池,分别为:

1)newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。

2)newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。

3)newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。

4)newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。

//jdk中提供的四种快速创建线程池的方式
    //1.定长线程池
    ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);
    //2.缓存线程池
    ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
    //3.周期线程池,可用来实现定时任务
    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(10);
    //4.单线程线程池
    ExecutorService executorService = Executors.newSingleThreadExecutor();

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • java 多线程饥饿现象的问题解决方法

    java 多线程饥饿现象的问题解决方法 当有线程正在读的时候,不允许写 线程写,但是允许其他的读线程进行读.有写线程正在写的时候,其他的线程不应该读写.为了防止写线程出现饥饿现象,当线程正在读,如果写线程请求写,那么应该禁止再来的读线程进行读. 实现代码如下: File.Java package readerWriter; public class File { private String name; public File(String name) { this.name=name; } }

  • Java编程一道多线程问题实例代码

    前面几篇博文基本上总结了一下java并发里的一些内容,这篇博文主要从一个问题入手,看看都能用到前面总结的哪些并发技术去解决. 题目描述: 模拟一个场景:处理16条日志记录,每条日志记录打印时间需要1秒,正常情况下如果将这16条记录去部打完需要16秒,现在为了提高效率,准备开启4个线程去打印,4秒钟打印完,实现这个demo. 先来分析一下这个题目,关于这16条日志记录,我们可以在主线程中产生出来,这没用什么难度,关键是开启4个线程去执行,现在有两种思路:一种是日志的产生和打印日志的线程在逻辑上分开

  • 以银行取钱为例模拟Java多线程同步问题完整代码

    简单了解下在操作系统中进程和线程的区别: 进程:每个进程都有独立的代码和数据空间(进程上下文),进程间的切换会有较大的开销,一个进程包含1--n个线程.(进程是资源分配的最小单位) 线程:同一类线程共享代码和数据空间,每个线程有独立的运行栈和程序计数器(PC),线程切换开销小.(线程是cpu调度的最小单位) 线程和进程一样分为五个阶段:创建.就绪.运行.阻塞.终止. 多进程是指操作系统能同时运行多个任务(程序). 多线程是指在同一程序中有多个顺序流在执行.首先存钱取钱的这个操作,应该是线程操作的

  • Java多线程模拟售票程序和线程安全问题

    Java中线程部分知识中,售票程序非常经典.程序中也有一些问题存在! 需求:模拟3个窗口同时在售100张票. 问题1:为什么100张票被卖出了300张票? 原因:因为tickets是非静态的,非静态的成员变量数据是在每个对象中都会维护一份数据的,三个线程对象就会有三份. 解决方案:把tickets票数共享出来给三个线程对象使用.使用static修饰. 问题2: 出现了线程安全问题 ? 线程安全问题的解决方案:sun提供了线程同步机制让我们解决这类问题的. java线程同步机制的方式: 方式一:同

  • 完美解决Java中的线程安全问题

    给出一个问题,如下: 解决方案如下: public class Demo_5 { public static void main(String[] args) { //创建一个窗口 TicketWindow tw1=new TicketWindow(); //使用三个线程同时启动 Thread t1=new Thread(tw1); Thread t2=new Thread(tw1); Thread t3=new Thread(tw1); t1.start(); t2.start(); t3.s

  • 如何解决线程太多导致java socket连接池出现的问题

    这篇文章主要介绍了如何解决线程太多导致socket连接池出现的问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 线程太多导致socket连接池爆满,进程启动不了 问题: 某部机上跟其它机器的连接有问题,ping可以通,telnet端口不通,可以其它机器可以连接到该机器上的进程. java应用启动不起来,产生以下错误. java.net.SocketException: No buffer space available (maximum co

  • 如何实现Java线程安全问题

    这篇文章主要介绍了如何实现Java线程安全问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 解决线程安全问题的第一种方案:使用同步代码块 格式: synchronized(锁对象) { 可能会出现线程安全问题的代码(访问了共享数据的代码) } 注意:代码块中的锁对象,可以是任意对象,但必须保证多个线程之间使用的是同一个 锁对象的作用是把同步代码块锁住,同一时间只能让一个线程在同步代码块中执行 package com.fgy.demo02; /

  • 基于java线程安全问题及原理性分析

    1.什么是线程安全问题? 从某个线程开始访问到访问结束的整个过程,如果有一个访问对象被其他线程修改,那么对于当前线程而言就发生了线程安全问题:如果在整个访问过程中,无一对象被其他线程修改,就是线程安全的. 2.线程安全问题产生的根本原因 首先是多线程环境,即同时存在有多个操作者,单线程环境不存在线程安全问题.在单线程环境下,任何操作包括修改操作都是操作者自己发出的,操作者发出操作时不仅有明确的目的,而且意识到操作的影响. 多个操作者(线程)必须操作同一个对象,只有多个操作者同时操作一个对象,行为

  • 新手场景Java线程相关问题及解决方案

    一.创建线程方式 a. 继承线程类( new Thread),重写run方法: public class MyThread extends Thread{//继承Thread类 public void run(){ //重写run方法 } } public class Main { public static void main(String[] args){ new MyThread().start();//创建并启动线程 } } b. 实现runnable接口,将runnable对象传入Th

  • Java 线程相关总结

    一.线程的生命周期 1.五种状态:新建状态.就绪状态.运行状态.阻塞状态.消亡状态 2.就绪状态的线程表示有权利去获取CPU的时间片,CPU时间片是执行权,当线程拿到CPU时间片之后就马上执行run方法,这个时候就代表进入了运行状态 二.线程的调度与控制 通常我们的计算机只有一个CPU,CPU在某一个时刻只能执行一条指令,线程只有得到CPU时间片,也就是使用权,才可以执行指令​.在单CPU的机器上线程不是并行运行的,只有个在多个CPU上线程才可以并行运行.Java虚拟机要负责线程的调度,取得CP

  • 50 道Java 线程面试题(经典)

    下面是 Java 线程相关的热门面试题,你可以用它来好好准备面试. 1) 什么是线程? 线程是操作系统能够进行运算调度的最小单位,它被包含在进程之中,是进程中的实际运作单位.程序员可以通过它进行多处理器编程,你可以使用多线程对运算密集型任务提速.比如,如果一个线程完成一个任务要 100 毫秒,那么用十个线程完成改任务只需 10 毫秒.Java 在语言层面对多线程提供了卓越的支持,它也是一个很好的卖点.欲了解更多详细信息请点击这里. 2) 线程和进程有什么区别? 线程是进程的子集,一个进程可以有很

  • Java线程安全解决方案(synchronized,ReentrantLock,Atomic)

    线程安全解决方案 synchronized,ReentrantLock,Atomic 使用场景描述 在实际开发过程中如果服务量,请求频繁,就会经常碰见并发,这时候不做处理就会出现很多非法数据.这时候就需要解决线程安全的问题,这时候就可以使用java当中的锁机制.常用有java关键synchronized.可重入锁ReentrantLock,还有并发包下的Atomic 或者Concurrent的安全类型. synchronized使用场景: 在资源竞争不是很激烈的情况下,偶尔出现并发,需要同步的情

  • Java线程Dump分析工具jstack解析及使用场景

    jstack用于打印出给定的java进程ID或core file或远程调试服务的Java堆栈信息,如果是在64位机器上,需要指定选项"-J-d64",Windows的jstack使用方式只支持以下的这种方式: jstack [-l][F] pid 如果java程序崩溃生成core文件,jstack工具可以用来获得core文件的java stack和native stack的信息,从而可以轻松地知道java程序是如何崩溃和在程序何处发生问题.另外,jstack工具还可以附属到正在运行的j

  • 非常适合新手学生的Java线程池超详细分析

    目录 线程池的好处 创建线程池的五种方式 缓存线程池CachedThreadPool 固定容量线程池FixedThreadPool 单个线程池SingleThreadExecutor 定时任务线程池ScheduledThreadPool ThreadPoolExecutor创建线程池(十分推荐) ThreadPoolExecutor的七个参数详解 workQueue handler 如何触发拒绝策略和线程池扩容? 线程池的好处 可以实现线程的复用,避免重新创建线程和销毁线程.创建线程和销毁线程对

  • 非常适合新手学生的Java线程池优化升级版

    目录 升级版线程池的优化 线程池构造器 线程池拒绝策略 execute方法 手写线程池源码 MyExecutorService MyRejectedExecutionException MyRejectedExecutionHandle 核心类MyThreadPoolExecutor 线程池测试类 升级版线程池的优化 1:新增了4种拒绝策略.分别为:MyAbortPolicy.MyDiscardPolicy.MyDiscardOldestPolicy.MyCallerRunsPolicy 2:对

  • java线程池不同场景下使用示例经验总结

    目录 引导语 1.coreSize == maxSize 2.maxSize 无界 + SynchronousQueue 3.maxSize 有界 + Queue 无界 4.maxSize 有界 + Queue 有界 5.keepAliveTime 设置无穷大 6.线程池的公用和独立 7.如何算线程大小和队列大小 8.总结 引导语 ThreadPoolExecutor 初始化时,主要有如下几个参数: public ThreadPoolExecutor(int corePoolSize, int

  • Java线程安全问题的解决方案

    目录 线程安全问题演示 解决线程安全问题 1.原子类AtomicInteger 2.加锁排队执行 2.1 同步锁synchronized 2.2 可重入锁ReentrantLock 3.线程本地变量ThreadLocal 总结 前言: 线程安全是指某个方法或某段代码,在多线程中能够正确的执行,不会出现数据不一致或数据污染的情况,我们把这样的程序称之为线程安全的,反之则为非线程安全的.在 Java 中, 解决线程安全问题有以下 3 种手段: 使用线程安全类,比如 AtomicInteger. 加锁

  • JAVA 线程通信相关知识汇总

    两个线程之间的通信 多线程环境下CPU会随机的在线程之间进行切换,如果想让两个线程有规律的去执行,那就需要两个线程之间进行通信,在Object类中的两个方法wait和notify可以实现通信. wait方法可以使当前线程进入到等待状态,在没有被唤醒的情况下,线程会一直保持等待状态. notify方法可以随机唤醒单个在等待状态下的线程. 来实现这样的一个功能: 让两个线程交替在控制台输出一行文字 定义一个Print类,有两个方法print1和print2,分别打印一行不同的内容 package c

随机推荐