java 多线程

Posted 幽人月

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java 多线程相关的知识,希望对你有一定的参考价值。

不知道大家学习或者使用线程时有没有思考过什么是线程?

大多数书上或者文章上都是这么解释的:线程是程序中一个单一的顺序控制流程。进程内一个相对独立的、可调度的执行单元,是系统独立调度和分派CPU的基本单位指运行中的程序的调度单位。

这时候有没有产生第二个疑问:那么如何创建一个线程呢?

咱继续引经据典:1.利用Thread类的子类来创建线程2.利用Runnable接口来创建线程

此刻我的理解告诉我一个类继承Thread或者实现Runnable就算是一个线程了。但其实这样的理解会坑了自己。

比如我在思考线程池问题时就掉坑了,那既然无论是继承Thread还是实现Runnable都是线程,又说线程是独立的,那为何池中的线程还可以继续用呢?(第三个问题)

这个问题我开始不得其解,开始看书查资料

看到这篇关于讲解线程池原理的文章时我稍微了解了点http://blog.csdn.net/hsuxu/article/details/8985931

然后继续看了Thread和Runnable的源码时又明白了点。

public class Thread implements Runnable{
//此处只粘贴局部代码
 /* What will be run. */
    private Runnable target;

@Override
    public void run() {
        if (target != null) {
            target.run();
        }
    }
}

注意Thread 实现了RunnableThread 覆写run()中是用的target.run();

现在让我们再写2种实现线程方式的代码

 

public class ThreadTest1 extends Thread{

    @Override
    public void run() {
        for(int i = 0;i<10;i++){
            System.out.println(i);
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
    public static void main(String[] args) {
        new ThreadTest1().start();
    }
}

 

public class RunnableTest1 implements Runnable{

    @Override
    public void run() {
        for(int i = 0;i<10;i++){
            System.out.println(i);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
    public static void main(String[] args) {
        Thread thread = new Thread(new RunnableTest1());
        thread.start();
    }

}

继承了Thread的类用的是new ThreadTest1().start();

实现了Runnable的类用的是Thread thread = new Thread(new RunnableTest1()); thread.start();

也就是说,要启动一个线程就要调用Thread类(或者他的子类)start()方法

那么start()之后干了什么呢?

start()之后就是等待cpu资源然后运行run()。

此处高能预警

继承了Thread的类在启动时是真的启动了一个新的线程,而实现了Runnable的类(我感觉实现了Runnable的类应该说是定义了线程执行的任务类比叫他线程类更合适)是通过将他的实例放到一个Thread实例中来启动的

也就是设置了Thread中的

private Runnable target;

也就是说这个Thread可以放Runnable的A的实例也可以放Runnable的B的实例。这里差不多可以思考到我一个线程可以执行不同的任务!

但是真的可以在运行时修改线程中的private Runnable target;吗?答案我还不清楚。。。

不过呢,上面链接的文章给出了一个实现的方法

通过定义一个工作线程来实现,具体的看如下代码

 

private class WorkThread extends Thread {  
        // 该工作线程是否有效,用于结束该工作线程  
        private boolean isRunning = true;  
  
        /* 
         * 关键所在啊,如果任务队列不空,则取出任务执行,若任务队列空,则等待 
         */  
        @Override  
        public void run() {  
            Runnable r = null;  
            while (isRunning) {// 注意,若线程无效则自然结束run方法,该线程就没用了  
                synchronized (taskQueue) {  
                    while (isRunning && taskQueue.isEmpty()) {// 队列为空  
                        try {  
                            taskQueue.wait(20);  
                        } catch (InterruptedException e) {  
                            e.printStackTrace();  
                        }  
                    }  
                    if (!taskQueue.isEmpty())  
                        r = taskQueue.remove(0);// 取出任务  
                }  
                if (r != null) {  
                    r.run();// 执行任务  
                }  
                finished_task++;  
                r = null;  
            }  
        }  
  
        // 停止工作,让该线程自然执行完run方法,自然结束  
        public void stopWorker() {  
            isRunning = false;  
        }  
    }

 

他覆写了run()方法,在里面通过while循环和设置Runnable r = null; 的r的值来实现一个Thread执行不同的任务。这里我又产生了个疑问:可以不用Runnable 而随便用一个接口吗?比如,我定义一个Task接口

public interface Task {
    public abstract void doTask();
}

然后修改上面的WorkThread 类为

private class WorkThread extends Thread {  
        // 该工作线程是否有效,用于结束该工作线程  
        private boolean isRunning = true;  
  
        /* 
         * 关键所在啊,如果任务队列不空,则取出任务执行,若任务队列空,则等待 
         */  
        @Override  
        public void run() {  
            Task t = null;  
            while (isRunning) {// 注意,若线程无效则自然结束run方法,该线程就没用了  
                synchronized (taskQueue) {  
                    while (isRunning && taskQueue.isEmpty()) {// 队列为空  
                        try {  
                            taskQueue.wait(20);  
                        } catch (InterruptedException e) {  
                            e.printStackTrace();  
                        }  
                    }  
                    if (!taskQueue.isEmpty())  
                        t = taskQueue.remove(0);// 取出任务  
                }  
                if (t != null) {  
                    t.doTask();// 执行任务  
                }  
                finished_task++;  
                t = null;  
            }  
        }  
  
        // 停止工作,让该线程自然执行完run方法,自然结束  
        public void stopWorker() {  
            isRunning = false;  
        }  
    }

这样子不也一样吗?我暂时觉得没问题。。。我觉得之所以感觉Runnable和其他的不一样是因为Thread继承了Runnable,继而实现了run()方法,而线程启动后调用的就是这么个run方法从而显得Runnable与众不同。上面修改后的WorkThread在覆写run()方法时修改了真正执行的任务,那我觉得随便定义一个接口里面定义了运行的任务就好啦。

 

以上是今天对于线程池的小小的思考。

 

以上是关于java 多线程的主要内容,如果未能解决你的问题,请参考以下文章

Java多线程与并发库高级应用-工具类介绍

多线程 Thread 线程同步 synchronized

Java多线程具体解释

自己开发的在线视频下载工具,基于Java多线程

什么是JAVA的多线程?

多个用户访问同一段代码