how2j.cn


工具版本兼容问题
多线程即在同一时间,可以做多件事情。

创建多线程有3种方式,分别是继承线程类,实现Runnable接口,匿名类


本视频是解读性视频,所以希望您已经看过了本知识点的内容,并且编写了相应的代码之后,带着疑问来观看,这样收获才多。 不建议一开始就观看视频



16分13秒
本视频采用html5方式播放,如无法正常播放,请将浏览器升级至最新版本,推荐火狐,chrome,360浏览器 如果装有迅雷,播放视频呈现直接下载状态,请调整 迅雷系统设置-基本设置-启动-监视全部浏览器 (去掉这个选项)



步骤 1 : 线程概念   
步骤 2 : 创建多线程-继承线程类   
步骤 3 : 创建多线程-实现Runnable接口   
步骤 4 : 创建多线程-匿名类   
步骤 5 : 创建多线程的三种方式   
步骤 6 : 练习-同步查找文件内容   
步骤 7 : 答案-同步查找文件内容   

首先要理解进程(Processor)和线程(Thread)的区别
进程:启动一个LOL.exe就叫一个进程。 接着又启动一个DOTA.exe,这叫两个进程。
线程:线程是在进程内部同时做的事情,比如在LOL里,有很多事情要同时做,比如"盖伦” 击杀“提莫”,同时“赏金猎人”又在击杀“盲僧”,这就是由多线程来实现的。


此处代码演示的是不使用多线程的情况
只有在盖伦杀掉提莫后,赏金猎人才开始杀盲僧
线程概念
package charactor; import java.io.Serializable; public class Hero{ public String name; public float hp; public int damage; public void attackHero(Hero h) { try { //为了表示攻击需要时间,每次攻击暂停1000毫秒 Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } h.hp-=damage; System.out.format("%s 正在攻击 %s, %s的血变成了 %.0f%n",name,h.name,h.name,h.hp); if(h.isDead()) System.out.println(h.name +"死了!"); } public boolean isDead() { return 0>=hp?true:false; } }
package multiplethread; import charactor.Hero; public class TestThread { public static void main(String[] args) { Hero gareen = new Hero(); gareen.name = "盖伦"; gareen.hp = 616; gareen.damage = 50; Hero teemo = new Hero(); teemo.name = "提莫"; teemo.hp = 300; teemo.damage = 30; Hero bh = new Hero(); bh.name = "赏金猎人"; bh.hp = 500; bh.damage = 65; Hero leesin = new Hero(); leesin.name = "盲僧"; leesin.hp = 455; leesin.damage = 80; //盖伦攻击提莫 while(!teemo.isDead()){ gareen.attackHero(teemo); } //赏金猎人攻击盲僧 while(!leesin.isDead()){ bh.attackHero(leesin); } } }
步骤 2 :

创建多线程-继承线程类

edit
使用多线程,就可以做到盖伦在攻击提莫的同时,赏金猎人也在攻击盲僧
设计一个类KillThread 继承Thread并且重写run方法
启动线程办法: 实例化一个KillThread对象,并且调用其start方法
就可以观察到 赏金猎人攻击盲僧的同时,盖伦也在攻击提莫
创建多线程-继承线程类
package multiplethread; import charactor.Hero; public class KillThread extends Thread{ private Hero h1; private Hero h2; public KillThread(Hero h1, Hero h2){ this.h1 = h1; this.h2 = h2; } public void run(){ while(!h2.isDead()){ h1.attackHero(h2); } } }
package multiplethread; import charactor.Hero; public class TestThread { public static void main(String[] args) { Hero gareen = new Hero(); gareen.name = "盖伦"; gareen.hp = 616; gareen.damage = 50; Hero teemo = new Hero(); teemo.name = "提莫"; teemo.hp = 300; teemo.damage = 30; Hero bh = new Hero(); bh.name = "赏金猎人"; bh.hp = 500; bh.damage = 65; Hero leesin = new Hero(); leesin.name = "盲僧"; leesin.hp = 455; leesin.damage = 80; KillThread killThread1 = new KillThread(gareen,teemo); killThread1.start(); KillThread killThread2 = new KillThread(bh,leesin); killThread2.start(); } }
步骤 3 :

创建多线程-实现Runnable接口

edit
创建类Battle,实现Runnable接口
启动的时候,首先创建一个Battle对象,然后再根据该battle对象创建一个线程对象,并启动

Battle battle1 = new Battle(gareen,teemo);
new Thread(battle1).start();

battle1 对象实现了Runnable接口,所以有run方法,但是直接调用run方法,并不会启动一个新的线程。
必须,借助一个线程对象的start()方法,才会启动一个新的线程。
所以,在创建Thread对象的时候,把battle1作为构造方法的参数传递进去,这个线程启动的时候,就会去执行battle1.run()方法了。

package multiplethread; import charactor.Hero; public class Battle implements Runnable{ private Hero h1; private Hero h2; public Battle(Hero h1, Hero h2){ this.h1 = h1; this.h2 = h2; } public void run(){ while(!h2.isDead()){ h1.attackHero(h2); } } }
package multiplethread; import charactor.Hero; public class TestThread { public static void main(String[] args) { Hero gareen = new Hero(); gareen.name = "盖伦"; gareen.hp = 616; gareen.damage = 50; Hero teemo = new Hero(); teemo.name = "提莫"; teemo.hp = 300; teemo.damage = 30; Hero bh = new Hero(); bh.name = "赏金猎人"; bh.hp = 500; bh.damage = 65; Hero leesin = new Hero(); leesin.name = "盲僧"; leesin.hp = 455; leesin.damage = 80; Battle battle1 = new Battle(gareen,teemo); new Thread(battle1).start(); Battle battle2 = new Battle(bh,leesin); new Thread(battle2).start(); } }
步骤 4 :

创建多线程-匿名类

edit
使用匿名类,继承Thread,重写run方法,直接在run方法中写业务代码
匿名类的一个好处是可以很方便的访问外部的局部变量。
前提是外部的局部变量需要被声明为final。(JDK7以后就不需要了)
package multiplethread; import charactor.Hero; public class TestThread { public static void main(String[] args) { Hero gareen = new Hero(); gareen.name = "盖伦"; gareen.hp = 616; gareen.damage = 50; Hero teemo = new Hero(); teemo.name = "提莫"; teemo.hp = 300; teemo.damage = 30; Hero bh = new Hero(); bh.name = "赏金猎人"; bh.hp = 500; bh.damage = 65; Hero leesin = new Hero(); leesin.name = "盲僧"; leesin.hp = 455; leesin.damage = 80; //匿名类 Thread t1= new Thread(){ public void run(){ //匿名类中用到外部的局部变量teemo,必须把teemo声明为final //但是在JDK7以后,就不是必须加final的了 while(!teemo.isDead()){ gareen.attackHero(teemo); } } }; t1.start(); Thread t2= new Thread(){ public void run(){ while(!leesin.isDead()){ bh.attackHero(leesin); } } }; t2.start(); } }
步骤 5 :

创建多线程的三种方式

edit
把上述3种方式再整理一下:

1. 继承Thread类
2. 实现Runnable接口
3. 匿名类的方式

注: 启动线程是start()方法,run()并不能启动一个新的线程
步骤 6 :

练习-同步查找文件内容

edit Or  姿势不对,事倍功半! 点击查看做练习的正确姿势
练习-查找文件内容 改为多线程查找文件内容
原练习的思路是遍历所有文件,当遍历到文件是 .java的时候,查找这个文件的内容,查找完毕之后,再遍历下一个文件

现在通过多线程调整这个思路:
遍历所有文件,当遍历到文件是.java的时候,创建一个线程去查找这个文件的内容,不必等待这个线程结束,继续遍历下一个文件
步骤 7 :

答案-同步查找文件内容

edit
在查看答案前,尽量先自己完成,碰到问题再来查看答案,收获会更多
在查看答案前,尽量先自己完成,碰到问题再来查看答案,收获会更多
在查看答案前,尽量先自己完成,碰到问题再来查看答案,收获会更多
查看本答案会花费4个积分,您目前总共有点积分。查看相同答案不会花费额外积分。 积分增加办法 或者一次性购买JAVA 中级总计0个答案 (总共需要0积分)
查看本答案会花费4个积分,您目前总共有点积分。查看相同答案不会花费额外积分。 积分增加办法 或者一次性购买JAVA 中级总计0个答案 (总共需要0积分)
账号未激活 账号未激活,功能受限。 请点击激活
本视频是解读性视频,所以希望您已经看过了本答案的内容,带着疑问来观看,这样收获才多。 不建议一开始就观看视频

6分33秒 本视频采用html5方式播放,如无法正常播放,请将浏览器升级至最新版本,推荐火狐,chrome,360浏览器 如果装有迅雷,播放视频呈现直接下载状态,请调整 迅雷系统设置-基本设置-启动-监视全部浏览器 (去掉这个选项)


首先准备一个SerachFileThread,继承Thread类,并重写run方法。 在run方法中,读取文件内容并查找

然后在遍历文件的时候,如果是以.java结尾,则启动一个SerachFileThread线程,进行查找工作
package multiplethread; import java.io.File; import java.io.FileReader; import java.io.IOException; public class SearchFileThread extends Thread{ private File file; private String search; public SearchFileThread(File file,String search) { this.file = file; this.search= search; } public void run(){ String fileContent = readFileConent(file); if(fileContent.contains(search)){ System.out.printf("找到子目标字符串%s,在文件:%s%n",search,file); } } public String readFileConent(File file){ try (FileReader fr = new FileReader(file)) { char[] all = new char[(int) file.length()]; fr.read(all); return new String(all); } catch (IOException e) { e.printStackTrace(); return null; } } }
package multiplethread; import java.io.File; public class TestThread { public static void search(File file, String search) { if (file.isFile()) { if(file.getName().toLowerCase().endsWith(".java")){ //当找到.java文件的时候,就启动一个线程,进行专门的查找 new SearchFileThread(file,search).start(); } } if (file.isDirectory()) { File[] fs = file.listFiles(); for (File f : fs) { search(f, search); } } } public static void main(String[] args) { File folder =new File("e:\\project"); search(folder,"Magic"); } }


HOW2J公众号,关注后实时获知最新的教程和优惠活动,谢谢。


问答区域    
2019-11-16 小企业的作业Time-同步查找文件
小企业哒




一定要使用.start();来启动线程 修改前将查找字符串的代码全部放到了重写的'run'方法中,在看了站长的代码后发现我得run方法显得过于杂乱,于是照着站长的代码将部分代码移出去新建了一个方法,这样就显得不那么杂乱.
加载中 >
////// 实现Runnable接口
public class HomeWork1 {

	// 练习-同步查找文件内容
	// 遍历所有文件,当遍历到文件是.java的时候,创建一个线程去查找这个文件的内容
	// 不必等待这个线程结束,继续遍历下一个文件

	public static void main(String[] args) {

		File folder = new File("D:\\murasame");
		String search = "murasame";

		searchFile(folder, search);
	}

	private static void searchFile(File folder, String search) {

		// 检查文件夹是否存在
		if (!folder.exists()) {
			System.err.println("警告,指定的文件夹不存在,请检查重试.");
			return;
		}

		// 如果是文件并且以.java为后缀,创建一个线程去查找这个文件的内容
		if (folder.isFile() && folder.getAbsolutePath().endsWith(".java")) {
			SearchString1 searchString = new SearchString1(folder, search);
			new Thread(searchString).start();
		}
		// 如果是文件夹,创建文件数组存放文件夹下的所有文件,并利用递归遍历文件夹的子文件
		if (folder.isDirectory()) {
			File[] fileArray = folder.listFiles();
			if (null != fileArray) {
				for (File file : fileArray) {
					searchFile(file, search);
				}
			}
		}
	}
}

public class SearchString1 implements Runnable {

	// 实现Runnable接口

	private File file;
	private String search;

	public SearchString1(File file, String search) {
		this.file = file;
		this.search = search;
	}

	@Override
	public void run() {
		// 获取方法返回的字符串
		String mark = searchFile(file);
		// 利用contains判断是否存在指定字符串
		if (mark.contains(search)) {
			System.out.printf("找到字符串: %s,在文件: %s%n", search, file.getAbsolutePath());
		}
	}

	public String searchFile(File file) {
		try (FileInputStream fis = new FileInputStream(file)) {
			byte[] array = new byte[(int) file.length()];
			fis.read(array);
			return new String(array);

		} catch (IOException e) {
			e.printStackTrace();
			return null;
		}
	}
}

////// 继承线程类
public class SearchString2 extends Thread {

	// 继承线程类

	private File file;
	private String search;

	public SearchString2(File file, String search) {
		this.file = file;
		this.search = search;
	}

	@Override
	public void run() {
		// 获取方法返回的字符串
		String mark = searchFile(file);
		// 利用contains判断是否存在指定字符串
		if (mark.contains(search)) {
			System.out.printf("找到字符串: %s,在文件: %s%n", search, file.getAbsolutePath());
		}
	}

	public String searchFile(File file) {
		try (FileInputStream fis = new FileInputStream(file)) {
			byte[] array = new byte[(int) file.length()];
			fis.read(array);
			return new String(array);

		} catch (IOException e) {
			e.printStackTrace();
			return null;
		}
	}
}

////// 匿名类
public class HomeWork3 {

	// 练习-同步查找文件内容
	// 遍历所有文件,当遍历到文件是.java的时候,创建一个线程去查找这个文件的内容
	// 不必等待这个线程结束,继续遍历下一个文件

	public static void main(String[] args) {

		File folder = new File("D:\\murasame");
		String search = "murasame";

		searchFile(folder, search);
	}

	private static void searchFile(File folder, String search) {

		// 检查文件夹是否存在
		if (!folder.exists()) {
			System.err.println("警告,指定的文件夹不存在,请检查重试.");
			return;
		}

		// 如果是文件并且以.java为后缀,创建一个线程去查找这个文件的内容
		if (folder.isFile() && folder.getAbsolutePath().endsWith(".java")) {

			// 匿名类
			Thread t = new Thread() {
				@Override
				public void run() {
					// 获取方法返回的字符串
					String mark = searchFile(folder);
					// 利用contains判断是否存在指定字符串
					if (mark.contains(search)) {
						System.out.printf("找到字符串: %s,在文件: %s%n", search, folder.getAbsolutePath());
					}
				}

				public String searchFile(File file) {
					try (FileInputStream fis = new FileInputStream(file)) {
						byte[] array = new byte[(int) file.length()];
						fis.read(array);
						return new String(array);

					} catch (IOException e) {
						e.printStackTrace();
						return null;
					}
				}
			};
			t.start();
		}
		// 如果是文件夹,创建文件数组存放文件夹下的所有文件,并利用递归遍历文件夹的子文件
		if (folder.isDirectory())

		{
			File[] fileArray = folder.listFiles();
			if (null != fileArray) {
				for (File file : fileArray) {
					searchFile(file, search);
				}
			}
		}
	}
}

							





回答已经提交成功,正在审核。 请于 我的回答 处查看回答记录,谢谢
答案 或者 代码至少填写一项, 如果是自己有问题,请重新提问,否则站长有可能看不到





2019-11-07 交作业
String899




才刚尝试多线程
package test;

import java.io.File;
import java.io.FileReader;

public class Test3 {

	public static void queryFiles(File f, String queryValue) throws Exception {
		File[] files = f.listFiles();
		for (File file : files) {
			if (file.isFile()) {
				if (file.getName().endsWith("java")) {
					Thread thread2 = new Thread(new Runnable() {
						@Override
						public void run() {
							String fileContent;
							try {
								fileContent = readFile(file);
								if (fileContent.contains(queryValue)) {
									System.out.println(file.getPath());
								}
							} catch (Exception e) {
								e.printStackTrace();
							}
						}
					});
					thread2.start();
				}
			}
			if (file.isDirectory()) {
				queryFiles(file, queryValue);
			}
		}
	}

	public static String readFile(File file) throws Exception {
		FileReader fileReader = new FileReader(file);
		char[] all = new char[(int) file.length()];
		fileReader.read(all);
		String fileContent = new String(all);
		return fileContent;
	}

	public static void main(String[] args) throws Exception {
		File file = new File("F:/eclipse-workspace/test");

		Thread thread1 = new Thread(new Runnable() {
			public void run() {
				try {
					long startTime = System.currentTimeMillis();
					queryFiles(file, "main");
					long endTime = System.currentTimeMillis();
					System.out.println(endTime - startTime);
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		});
		thread1.start();
	}
}

							





回答已经提交成功,正在审核。 请于 我的回答 处查看回答记录,谢谢
答案 或者 代码至少填写一项, 如果是自己有问题,请重新提问,否则站长有可能看不到





2019-11-04 交作业
2019-11-04 Hero里面的name的值是怎样传过来的,不是只传了h2吗
2019-11-04 Hero里面的name的值是怎样传过来的,不是只传了h2吗
2019-10-14 为什么你们这么优秀 作业我做不出来啊
2019-09-10 交作业
2019-09-07 不知道对不对,希望站长检查一下
2019-09-06 作业,不知道对不对,希望有大神检查一下
2019-08-07 提交作业
2019-07-29 作业:多线程查找文件内容
2019-07-29 我感觉我的代码没问题啊,为啥运行了结果出不来
2019-07-24 交作业
2019-07-15 交作业
2019-06-25 练习-同步查找文件内容
2019-06-24 作业
2019-06-19 想了半天我这么写有毛病吗,总觉得不对
2019-06-09 ZZ交作业 多线程寻找包含特定内容的文件
2019-06-02 交作业
2019-05-27 交作业
2019-05-16 多线程找字符串
2019-05-16 同步查找文件的结果与非同步的结果不同
2019-05-14 Thread
2019-04-26 交一波
2019-04-22 交作业(一),欢迎暂时没思路的朋友来交流参考
2019-04-16 怎么获得发现"Magic"的线程ID呢?
2019-04-09 交作业ii -- 使用extends Thread方式
2019-04-06 大概写了下 不知道其他地方有问题没
2019-03-31 Runnable接口 的run 方法没有返回结果。站长讲讲Callable啊
2019-03-30 作业
2019-03-26 代码
2019-03-24 作业
2019-03-13 作业
2019-03-04 想了解下输出format 里面%s那一段
2019-03-04 多线程是针对类的还是针对事件的?
2019-03-01 作业~
2019-02-25 作业
2019-02-24 作业
2019-01-31 为什么要重写run方法呢不写不行吗
2018-12-31 作业
2018-12-24 用匿名类实现,但是不知道是否正确
2018-11-21 改了好久才改好
2018-10-11 交作业,匿名类实现。我看了很多同学教的作业,受教了,取长补短,答案不只有一个,各有优势。谢谢站长提供平台
2018-09-10 作业,通过实现Runnable接口来改造
2018-09-04 交作业,匿名内部类实现
2018-08-05 查找文件
2018-07-31 交作业
2018-07-26 报错问题
2018-07-06 实现runnable接口问题,求回答
2018-07-06 实现runnable接口问题
2018-06-28 粗心
2018-06-14 第二种实现runable的方法可以用lambda表达式
2018-04-18 大家看看对不对
2018-04-01 交作业,请问搜索时文件夹也用个线程会快点吗
2018-03-15 请问我这么写到底有没有实现目标?
2018-03-10 希望在多线程中加入线程变量的释义
2018-03-07 线程讲解误区
2018-03-05 return 0>=hp?true:false;
2018-02-14 三种启动线程的速度问题
2017-11-25 这个匿名类真心不想看
2017-11-19 序列化的包???
2017-11-14 使用多线程读取文件,会不会程序输出的时间会快一些呢?
2017-09-16 步骤1报错
2017-09-16 关于步骤1
2017-08-11 关于计数器的问题
2017-06-27 运行报错
2017-05-31 大佬,我在参看其他资料时,还提到有一个方法:通过Callable和Future创建线程
2017-04-05 可以用匿名类的方式吗?
2016-10-18 发现最近老司机挺粗心的,还是觉得没必要写出了,不过我还是说一下吧,好多继承老司机都不写出来了
2016-07-29 其实我觉得少设置点类类型的变量,不然就把那个类的完整的代码贴出来
2016-02-14 其实就是文字有误




提问之前请登陆
提问已经提交成功,正在审核。 请于 我的提问 处查看提问记录,谢谢
关于 JAVA 中级-多线程-启动一个线程 的提问

尽量提供截图代码异常信息,有助于分析和解决问题。 也可进本站QQ群交流: 881555796
提问尽量提供完整的代码,环境描述,越是有利于问题的重现,您的问题越能更快得到解答。
对教程中代码有疑问,请提供是哪个步骤,哪一行有疑问,这样便于快速定位问题,提高问题得到解答的速度
在已经存在的几千个提问里,有相当大的比例,是因为使用了和站长不同版本的开发环境导致的,比如 jdk, eclpise, idea, mysql,tomcat 等等软件的版本不一致。
请使用和站长一样的版本,可以节约自己大量的学习时间。 站长把教学中用的软件版本整理了,都统一放在了这里, 方便大家下载: https://how2j.cn/k/helloworld/helloworld-version/1718.html

上传截图