Java多线程之Runable与Thread

Java多线程是Java开发中的基础内容,但是涉及到高并发就有很深的研究可做了。

最近看了下《Java并发实战》,发先有些地方,虽然可以理解,但是自己在应用中很难下手。

  所以还是先回顾一下基础知识:

Java中的线程

  线程的相关知识,了解操作系统的基本都能有所了解。

  线程有5中状态,基本变化如图所示:

如何在Java代码中创建线程

  众所周知,Java创建线程有两种方式:

  1 实现Runable接口

  2 继承Thread类

  那么这两种方式有什么区别呢?

  1 Runable属于接口,所以可以有多个实现;Thread只有一个。

  2 实现Runable的线程类,可以被多个线程实例共享数据。

  举个简单的例子,火车站售票处一共有3个售票口,但是只剩下5张票:

  如果单纯使用Thread实现3个售票口的售票过程:

package com.imooc.test;
class MyThread extends Thread{

    private int ticketsCount = 5;
    private String name;

    public MyThread(String name){
        this.name = name;
    }

    @Override
    public void run() {
        while(ticketsCount > 0){
            ticketsCount--;
            System.out.println(name+" 卖了一张票,还剩下:"+ticketsCount);
        }
    }
}
public class TicketsTestThread {
    public static void main(String[] args) {
        MyThread mt1 = new MyThread("窗口1");
        MyThread mt2 = new MyThread("窗口2");
        MyThread mt3 = new MyThread("窗口3");

        mt1.start();
        mt2.start();
        mt3.start();
    }
}

  执行结果如下:

窗口1 卖了一张票,还剩下:4
窗口2 卖了一张票,还剩下:4
窗口1 卖了一张票,还剩下:3
窗口1 卖了一张票,还剩下:2
窗口1 卖了一张票,还剩下:1
窗口1 卖了一张票,还剩下:0
窗口2 卖了一张票,还剩下:3
窗口2 卖了一张票,还剩下:2
窗口2 卖了一张票,还剩下:1
窗口2 卖了一张票,还剩下:0
窗口3 卖了一张票,还剩下:4
窗口3 卖了一张票,还剩下:3
窗口3 卖了一张票,还剩下:2
窗口3 卖了一张票,还剩下:1
窗口3 卖了一张票,还剩下:0

  可以看到每个线程拥有自己的5张票,其实是重复了!

  那么如果使用Runnable,则不会出现这种情况:

package com.imooc.test;
class MyRunnable implements Runnable{

    private int ticketsCount = 5;

    @Override
    public void run() {
        while(ticketsCount > 0){
            ticketsCount--;
            System.out.println(Thread.currentThread().getName()+" 卖了一张票,还剩下:"+ticketsCount);
        }
    }
}
public class TicketsTestRunnable {
    public static void main(String[] args) {
        MyRunnable mr = new MyRunnable();
        Thread th1 = new Thread(mr,"窗口1");
        Thread th2 = new Thread(mr,"窗口2");
        Thread th3 = new Thread(mr,"窗口3");

        th1.start();
        th2.start();
        th3.start();
    }
}

  执行结果:

窗口1 卖了一张票,还剩下:4
窗口3 卖了一张票,还剩下:2
窗口3 卖了一张票,还剩下:1
窗口3 卖了一张票,还剩下:0
窗口2 卖了一张票,还剩下:3

  这是因为创建Thread实例时,使用的是同一个MyRunnable类对象,所以会共享其中的数据。

用户线程与守护线程

  在Java线程中,共有两类线程:

  1 用户线程:用户代码生成

  2 守护线程:用于特定的功能,当用户线程都结束时,守护线程会随着JVM的停止而停止,因此守护线程不能用于IO操作。

  那么下面一个简单的守护线程的例子:

  创建一个守护线程,持续不断的向文件中写入数据。主线程中启动该线程,然后主线程在一定时间后,退出。

  观察守护线程的状态!

  代码如下:

package com.imooc.test;

import java.io.File;
import java.io.FileOutputStream;
import java.io.OutputStream;
import java.util.Scanner;

class DaemonThread implements Runnable{
    public void run() {
        System.out.println("进入守护线程:"+Thread.currentThread().getName());
        try {
            Write2File();
        } catch (Exception e) {
            e.printStackTrace();
        }
        System.out.println("退出守护线程:"+Thread.currentThread().getName());
    }
    public void Write2File() throws Exception{
        File filename = new File("d:"+File.separator+"daemon.txt");
        OutputStream os = new FileOutputStream(filename,true);
        int count = 0;
        while(count < 999){
            os.write(("\r\nword "+count).getBytes());
            System.out.println("守护线程"+Thread.currentThread().getName()+
                    "写入了 "+count);
            count++;
            Thread.sleep(1000);
        }
    }
}
public class DaemonTest {
    public static void main(String[] args) {
        System.out.println("进入主线程"+Thread.currentThread().getName());
        DaemonThread dt = new DaemonThread();
        Thread th = new Thread(dt);
        th.setDaemon(true);
        th.start();

        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } 

        System.out.println("退出主线程"+Thread.currentThread().getName());
    }
}

  当主线程睡眠了5秒后,便结束。此时JVM中没有其他的用户线程,于是守护线程也直接退出。

  执行结果如下:

进入主线程main
进入守护线程:Thread-0
守护线程Thread-0写入了 0
守护线程Thread-0写入了 1
守护线程Thread-0写入了 2
守护线程Thread-0写入了 3
守护线程Thread-0写入了 4
退出主线程main

  可以看到守护线程直接就中断退出了!

  鉴于守护线程的这种特性,常用于实时监控系统状态。比如数据库,JVM等等。

查看线程快照

  通过使用Jstack.exe程序,可以帮助用户查看线程状态。

  使用方法:

  1 查询线程PID

  2 在cmd中输入jstack -l pid

C:\Users\Administrator>jstack -l 5028
2015-04-01 17:43:30
Full thread dump Java HotSpot(TM) Client VM (24.60-b09 mixed mode, sharing):

"Thread-0" daemon prio=6 tid=0x00928800 nid=0x2798 waiting on condition [0x03d4f
000]
   java.lang.Thread.State: TIMED_WAITING (sleeping)
        at java.lang.Thread.sleep(Native Method)
        at com.imooc.test.DaemonThread.Write2File(DaemonTest.java:27)
        at com.imooc.test.DaemonThread.run(DaemonTest.java:12)
        at java.lang.Thread.run(Unknown Source)

   Locked ownable synchronizers:
        - None

"Service Thread" daemon prio=6 tid=0x008de000 nid=0xd64 runnable [0x00000000]
   java.lang.Thread.State: RUNNABLE

   Locked ownable synchronizers:
        - None

"C1 CompilerThread0" daemon prio=10 tid=0x008dc400 nid=0x2158 waiting on conditi
on [0x00000000]
   java.lang.Thread.State: RUNNABLE

   Locked ownable synchronizers:
        - None

"Attach Listener" daemon prio=10 tid=0x008f4800 nid=0x13e0 waiting on condition
[0x00000000]
   java.lang.Thread.State: RUNNABLE

   Locked ownable synchronizers:
        - None

"Signal Dispatcher" daemon prio=10 tid=0x00905800 nid=0x1c7c runnable [0x0000000
0]
   java.lang.Thread.State: RUNNABLE

   Locked ownable synchronizers:
        - None

"Finalizer" daemon prio=8 tid=0x00875800 nid=0x2460 in Object.wait() [0x03e0f000
]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x23800fc8> (a java.lang.ref.ReferenceQueue$Lock)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        - locked <0x23800fc8> (a java.lang.ref.ReferenceQueue$Lock)
        at java.lang.ref.ReferenceQueue.remove(Unknown Source)
        at java.lang.ref.Finalizer$FinalizerThread.run(Unknown Source)

   Locked ownable synchronizers:
        - None

"Reference Handler" daemon prio=10 tid=0x00870800 nid=0x21c8 in Object.wait() [0
x03b6f000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x23800db0> (a java.lang.ref.Reference$Lock)
        at java.lang.Object.wait(Object.java:503)
        at java.lang.ref.Reference$ReferenceHandler.run(Unknown Source)
        - locked <0x23800db0> (a java.lang.ref.Reference$Lock)

   Locked ownable synchronizers:
        - None

"main" prio=6 tid=0x0099c000 nid=0x14b8 waiting on condition [0x0052f000]
   java.lang.Thread.State: TIMED_WAITING (sleeping)
        at java.lang.Thread.sleep(Native Method)
        at com.imooc.test.DaemonTest.main(DaemonTest.java:40)

   Locked ownable synchronizers:
        - None

"VM Thread" prio=10 tid=0x0086f000 nid=0x22dc runnable

"VM Periodic Task Thread" prio=10 tid=0x00927000 nid=0x131c waiting on condition

JNI global references: 111

C:\Users\Administrator>

  其中详细的描述了线程的名字,是否为守护线程,以及状态等等。

参考

  【1】慕课网Thread VS Runnable:http://www.imooc.com/learn/312

本文转自博客园xingoo的博客,原文链接:Java多线程之Runable与Thread,如需转载请自行联系原博主。

时间: 2024-09-25 03:50:12

Java多线程之Runable与Thread的相关文章

JAVA多线程之Thread&amp;&amp;Runnable 示例

看了个视频,嗯,记录下加深下理解...java实现多线程的两种方式:继承thread类,这种方式的缺陷就是java的单继承导致的:还有一种方式就是实现Runnable接口,这种方式避免了thread方式由于java单继承带来的缺陷.需要知道的是线程启动后会抢占CPU资源,如果当前new了一个线程,线程就会进入创建的状态,然后我们启动这个线程,thread.start(),这个时候这个线程就会处在就绪状态,如果当前能获取到CPU资源,然后就会处在运行状态,如果这个时候执行了sleep方法或者一些阻

学习Java多线程之volatile域_java

前言 有时仅仅为了读写一个或者两个实例域就使用同步的话,显得开销过大,volatile关键字为实例域的同步访问提供了免锁的机制.如果声明一个域为volatile,那么编译器和虚拟机就知道该域是可能被另一个线程并发更新的.再讲到volatile关键字之前我们需要了解一下内存模型的相关概念以及并发编程中的三个特性:原子性,可见性和有序性. 1. java内存模型与原子性,可见性和有序性 Java内存模型规定所有的变量都是存在主存当中,每个线程都有自己的工作内存.线程对变量的所有操作都必须在工作内存中

java多线程之:深入JVM锁机制2-Lock (转载)

前文(深入JVM锁机制-synchronized)分析了JVM中的synchronized实现,本文继续分析JVM中的另一种锁Lock的实现.与synchronized不同的是,Lock完全用Java写成,在java这个层面是无关JVM实现的. 在 java.util.concurrent.locks包中有很多Lock的实现类,常用的有ReentrantLock. ReadWriteLock(实现类ReentrantReadWriteLock),其实现都依赖 java.util.concurre

Java多线程之ThreadLocal

ThreadLocal的核心思想很简单:为每个独立的线程提供一个变量的副本. Java提供的synchronized关键字使用了"同步锁"的机制来阻止线程的竞争访问,即"以时间换空间".: " 10pt; FONT-SIZE:> ThreadLocal则使用了"拷贝副本"的方式,人人有份,你用你的,我用我的,大家互不影响,是"以空间换时间".每个线程修改变量时,实际上修改的是变量的副本,不怕影响到其它线程. 为

JAVA多线程之UncaughtExceptionHandler——处理非正常的线程中止

当单线程的程序发生一个未捕获的异常时我们可以采用try....catch进行异常的捕获,但是在多线程环境中,线程抛出的异常是不能用try....catch捕获的,这样就有可能导致一些问题的出现,比如异常的时候无法回收一些系统资源,或者没有关闭当前的连接等等. 首先来看一个示例: package com.exception; public class NoCaughtThread { public static void main(String[] args) { try { Thread thr

Java多线程之Lock的使用

import java.util.concurrent.ExecutorService;   import java.util.concurrent.Executors;   import java.util.concurrent.Future;   import java.util.concurrent.locks.Lock;   import java.util.concurrent.locks.ReadWriteLock;   import java.util.concurrent.loc

java多线程之wait(),notify(),notifyAll()的详解分析_java

wait(),notify(),notifyAll()不属于Thread类,而是属于Object基础类,也就是说每个对象都有wait(),notify(),notifyAll()的功能.因为每个对象都有锁,锁是每个对象的基础,当然操作锁的方法也是最基础了. wait导致当前的线程等待,直到其他线程调用此对象的 notify() 方法或 notifyAll() 方法,或被其他线程中断.wait只能由持有对像锁的线程来调用. notify唤醒在此对象监视器上等待的单个线程.如果所有线程都在此对象上等

Java多线程之synchronized关键字详解

多线程的同步机制对资源进行加锁,使得在同一个时间,只有一个线程可以进行操作,同步用以解决多个线程同时访问时可能出现的问题. 同步机制可以使用synchronized关键字实现. 当synchronized关键字修饰一个方法的时候,该方法叫做同步方法. 当synchronized方法执行完或发生异常时,会自动释放锁. 下面通过一个例子来对synchronized关键字的用法进行解析. 1,是否使用synchronized关键字的不同 public class ThreadTest  {      

java多线程之:Java中的ReentrantLock和synchronized两种锁定机制的对比 (转载)

原文:http://www.ibm.com/developerworks/cn/java/j-jtp10264/index.html 多线程和并发性并不是什么新内容,但是 Java 语言设计中的创新之一就是,它是第一个直接把跨平台线程模型和正规的内存模型集成到语言中的主流语言.核心类库包含一个 Thread 类,可以用它来构建.启动和操纵线程,Java 语言包括了跨线程传达并发性约束的构造 -- synchronized 和 volatile .在简化与平台无关的并发类的开发的同时,它决没有使并