您的位置:

java多线程学习与总结(java多线程处理数据)

本文目录一览:

北大青鸟java培训:Java多线程问题总结?

Java多线程分类中写了21篇多线程的文章,21篇文章的内容很多,个人认为,学习,内容越多、越杂的知识,越需要进行深刻的总结,这样才能记忆深刻,将知识变成自己的。

java课程培训机构认为这篇文章主要是对多线程的问题进行总结的,因此罗列了多个多线程的问题。

这些多线程的问题,有些来源于各大网站、有些来源于自己的思考。

(1)发挥多核CPU的优势随着工业的进步,现在的笔记本、台式机乃至商用的应用服务器至少也都是双核的,4核、8核甚至16核的也都不少见,如果是单线程的程序,那么在双核CPU上就浪费了50%,在4核CPU上就浪费了75%。

单核CPU上所谓的”多线程”那是假的多线程,同一时间处理器只会处理一段逻辑,只不过线程之间切换得比较快,看着像多个线程”同时”运行罢了。

多核CPU上的多线程才是真正的多线程,它能让你的多段逻辑同时工作,多线程,可以真正发挥出多核CPU的优势来,达到充分利用CPU的目的。

(2)防止阻塞从程序运行效率的角度来看,单核CPU不但不会发挥出多线程的优势,反而会因为在单核CPU上运行多线程导致线程上下文的切换,而降低程序整体的效率。

但是单核CPU我们还是要应用多线程,就是为了防止阻塞。

试想,如果单核CPU使用单线程,那么只要这个线程阻塞了,比方说远程读取某个数据吧,对端迟迟未返回又没有设置超时时间,那么你的整个程序在数据返回回来之前就停止运行了。

多线程可以防止这个问题,多条线程同时运行,哪怕一条线程的代码执行读取数据阻塞,也不会影响其它任务的执行。

(3)便于建模这是另外一个没有这么明显的优点了。

假设有一个大的任务A,单线程编程,那么就要考虑很多,建立整个程序模型比较麻烦。

但是如果把这个大的任务A分解成几个小任务,任务B、任务C、任务D,分别建立程序模型,并通过多线程分别运行这几个任务,那就简单很多了。

多线程回顾笔记总结

三种创建方式:

// 练习Thread,实现多线程同步下载图片

public class TestThread1 extends Thread {

private String name; // 保存文件名

// 创建一个构造器

public TestThread1(String url, String name) {

this.url = url;

this.name = name;

}

public static void main(String[] args) {

TestThread1 testThread1 = new TestThread1(";z=0ipn=falseword=qq%E5%A4%B4%E5%83%8Fhs=0pn=4spn=0di=179850pi=0rn=1tn=baiduimagedetailis=0%2C0ie=utf-8oe=utf-8cl=2lm=-1cs=1462782358%2C2840615474os=332435882%2C2135675601simid=3516664974%2C458125993adpicid=0lpn=0ln=30fr=alafm=sme=cg=headbdtype=0oriquery=qq%E5%A4%B4%E5%83%8Fobjurl=http%3A%2F%2F;fromurl=ippr_z2C%24qAzdH3FAzdH3Fooo_z%26e3B8-jyj_z%26e3BvgAzdH3FQQ%25E0%25l9%25AF%25EF%25Bl%25ba%25E0%25ln%25A0%25Em%25BE%25Bm%25Em%25lD%25l8%25Ec%25b9%25lA_z%26e3Bip4sgsm=5islist=querylist=","1.jpg");

TestThread1 testThread2 = new TestThread1(";z=0ipn=falseword=qq%E5%A4%B4%E5%83%8Fhs=0pn=8spn=0di=18480pi=0rn=1tn=baiduimagedetailis=0%2C0ie=utf-8oe=utf-8cl=2lm=-1cs=1756505232%2C2129310927os=3725694615%2C3696011658simid=3576571828%2C474240706adpicid=0lpn=0ln=30fr=alafm=sme=cg=headbdtype=0oriquery=qq%E5%A4%B4%E5%83%8Fobjurl=http%3A%2F%2F;fromurl=ippr_z2C%24qAzdH3FAzdH3F80qq_z%26e3Bv54AzdH3Fqqp57xtwg2AzdH3F8899l9m_rn_z%26e3Bip4sgsm=5islist=querylist=","2.jpg");

TestThread1 testThread3 = new TestThread1(";z=0ipn=falseword=qq%E5%A4%B4%E5%83%8Fhs=0pn=25spn=0di=132220pi=0rn=1tn=baiduimagedetailis=0%2C0ie=utf-8oe=utf-8cl=2lm=-1cs=1226648351%2C4217836os=1652635041%2C3404961290simid=3325093720%2C338083432adpicid=0lpn=0ln=30fr=alafm=sme=cg=headbdtype=0oriquery=qq%E5%A4%B4%E5%83%8Fobjurl=http%3A%2F%2F;fromurl=ippr_z2C%24qAzdH3FAzdH3Fooo_z%26e3Bprbb_z%26e3BgjpAzdH3Fp57xtwg2p7rtwgAzdH3Fgwgfijg2p57xtwg2AzdH3Fda8lAzdH3F8d89AzdH3F8dnb0_z%26e3Bip4sgsm=5islist=querylist=","3.jpg");

testThread1.start();

testThread2.start();

testThread3.start();

/* 结果,说明线程不是按代码先后顺序执行的,是同时执行的

下载了文件,名为:3.jpg

下载了文件,名为:1.jpg

下载了文件,名为:2.jpg

*/

}

// 下载图片的线程执行体

@Override

public void run() {

WebDownLoader webDownLoader = new WebDownLoader();

webDownLoader.downLoader(url,name);

System.out.println("下载了文件,名为:"+name);

}

}

// 下载器

class WebDownLoader {

// 下载方法

public void downLoader(String url,String name) {

try {

// copyURLToFile(),这个方法就是把网上的一个url变成一个文件

FileUtils.copyURLToFile(new URL(url),new File(name));

} catch (IOException e) {

e.printStackTrace();

System.out.println("IO异常,downLoader方法出错");

}

}

}

// 创建线程方式2:实现Runnable接口,重写run()方法,执行线程需要丢入Runnable接口实现类,调用start()方法

public class TestThread2 implements Runnable {

public static void main(String[] args) {

// 创建Runnable 接口实现类对象

TestThread2 testThread2 = new TestThread2();

// 创建线程对象,通过线程对象来开启我们的线程,代理

Thread thread = new Thread(testThread2);

thread.start();

//new Thread(testThread2).start(); // 简写方法

for (int i = 0; i 2000; i++) {

System.out.println("我们在学习多线程---"+i);

}

}

@Override

public void run() {

for (int i = 0; i 2000; i++) {

System.out.println("我们在玩 游戏 啦---"+i);

}

}

}

发现问题:多个线程操作同一个资源情况下,线程不安全,数据紊乱,出现重复数据

// 模拟龟兔赛跑

public class Race implements Runnable {

// 胜利者

private static String winner;

@Override

public void run() {

for (int i = 0; i = 100) {

winner = Thread.currentThread().getName();

System.out.println("winner is " + winner);

return true;

}

}

return false;

}

public static void main(String[] args) {

Race race = new Race();

new Thread(race, "兔子").start();

new Thread(race, "乌龟").start();

}

}

关闭服务:executorService.shutdownNow();

// 线程创建方式三:实现Callable接口

/*

* Callable的好处

* 1.可以定义返回值

* 2.可以抛出异常

**/

public class TestCallable implements Callable {

private String name; // 保存文件名

// 创建一个构造器

public TestCallable(String url, String name) {

this.url = url;

this.name = name;

}

public static void main(String[] args) throws ExecutionException, InterruptedException {

TestCallable testThread1 = new TestCallable(";z=0ipn=falseword=qq%E5%A4%B4%E5%83%8Fhs=0pn=4spn=0di=179850pi=0rn=1tn=baiduimagedetailis=0%2C0ie=utf-8oe=utf-8cl=2lm=-1cs=1462782358%2C2840615474os=332435882%2C2135675601simid=3516664974%2C458125993adpicid=0lpn=0ln=30fr=alafm=sme=cg=headbdtype=0oriquery=qq%E5%A4%B4%E5%83%8Fobjurl=http%3A%2F%2F;fromurl=ippr_z2C%24qAzdH3FAzdH3Fooo_z%26e3B8-jyj_z%26e3BvgAzdH3FQQ%25E0%25l9%25AF%25EF%25Bl%25ba%25E0%25ln%25A0%25Em%25BE%25Bm%25Em%25lD%25l8%25Ec%25b9%25lA_z%26e3Bip4sgsm=5islist=querylist=","1.jpg");

TestCallable testThread2 = new TestCallable(";z=0ipn=falseword=qq%E5%A4%B4%E5%83%8Fhs=0pn=8spn=0di=18480pi=0rn=1tn=baiduimagedetailis=0%2C0ie=utf-8oe=utf-8cl=2lm=-1cs=1756505232%2C2129310927os=3725694615%2C3696011658simid=3576571828%2C474240706adpicid=0lpn=0ln=30fr=alafm=sme=cg=headbdtype=0oriquery=qq%E5%A4%B4%E5%83%8Fobjurl=http%3A%2F%2F;fromurl=ippr_z2C%24qAzdH3FAzdH3F80qq_z%26e3Bv54AzdH3Fqqp57xtwg2AzdH3F8899l9m_rn_z%26e3Bip4sgsm=5islist=querylist=","2.jpg");

TestCallable testThread3 = new TestCallable(";z=0ipn=falseword=qq%E5%A4%B4%E5%83%8Fhs=0pn=25spn=0di=132220pi=0rn=1tn=baiduimagedetailis=0%2C0ie=utf-8oe=utf-8cl=2lm=-1cs=1226648351%2C4217836os=1652635041%2C3404961290simid=3325093720%2C338083432adpicid=0lpn=0ln=30fr=alafm=sme=cg=headbdtype=0oriquery=qq%E5%A4%B4%E5%83%8Fobjurl=http%3A%2F%2F;fromurl=ippr_z2C%24qAzdH3FAzdH3Fooo_z%26e3Bprbb_z%26e3BgjpAzdH3Fp57xtwg2p7rtwgAzdH3Fgwgfijg2p57xtwg2AzdH3Fda8lAzdH3F8d89AzdH3F8dnb0_z%26e3Bip4sgsm=5islist=querylist=","3.jpg");

// 创建执行服务

ExecutorService executorService = Executors.newFixedThreadPool(3);

// 提交执行

Future submit1 = executorService.submit(testThread1);

Future submit2 = executorService.submit(testThread2);

Future submit3 = executorService.submit(testThread3);

// 获取结果

Boolean b1 = submit1.get();

Boolean b2 = submit2.get();

Boolean b3 = submit3.get();

// 关闭服务

executorService.shutdownNow();

System.out.println(b1);

System.out.println(b2);

System.out.println(b3);

/* 结果,说明线程不是按代码先后顺序执行的,是同时执行的

下载了文件,名为:3.jpg

下载了文件,名为:1.jpg

下载了文件,名为:2.jpg

*/

}

// 下载图片的线程执行体

@Override

public Boolean call() {

WebDownLoader webDownLoader = new WebDownLoader();

webDownLoader.downLoader(url,name);

System.out.println("下载了文件,名为:"+name);

return true;

}

}

// 下载器

class WebDownLoader {

// 下载方法

public void downLoader(String url,String name) {

try {

// copyURLToFile(),这个方法就是把网上的一个url变成一个文件

FileUtils.copyURLToFile(new URL(url),new File(name));

} catch (IOException e) {

e.printStackTrace();

System.out.println("IO异常,downLoader方法出错");

}

}

}

静态代理模式总结:

真实对象和代理对象都要实现同一个接口

代理对象要代理真实角色

代理模式的好处:

代理对象可以做很多真实对象做不了的事情

真实对象专注做自己的事情就可以了, 其他的事情交给代理公司来做

new Thread(()- System.out.println("我爱你啊")).start();

public abstract void run();

}

五大状态:

// 测试Stop

// 1.建议线程正常停止,利用次数,不建议死循环

// 2.建议使用标志位,设置一个标志位

// 3.不要使用stop(),destroy()方法,已过时

public class StopTest implements Runnable {

// 1 设置一个标志位

private boolean flag = true;

public static void main(String[] args) {

StopTest stopTest = new StopTest();

// 开启线程

new Thread(stopTest).start();

for (int i = 0; i 1000; i++) {

System.out.println("main Thread is running..."+i);

if (i == 900) {

// 调用stop方法切换标志位停止线程

stopTest.stop();

System.out.println("Thread is stopped...");

}

}

}

// 设置一个公开的方法停止线程,转换标志位

public void stop() {

this.flag = false;

}

@Override

public void run() {

int i = 0;

while (flag) {

System.out.println("Thread is running..."+ i++);

}

}

}

yield

jion

daemon

// 化妆的方法,互相持有对方的锁,就是需要拿到对方的资源

private void makeup() throws InterruptedException {

if (choice == 0) {

synchronized (lipstick) { // 获得口红的锁

System.out.println(this.girlName+"获得口红的锁");

Thread.sleep(1000);

synchronized (mirror) { // 一秒后想获得镜子的锁

System.out.println(this.girlName+"获得镜子的锁");

}

}

} else {

synchronized (mirror) { // 获得镜子的锁

System.out.println(this.girlName+"获得镜子的锁");

Thread.sleep(2000);

synchronized (lipstick) { // 一秒后想获得口红的锁

System.out.println(this.girlName+"获得口红的锁");

}

}

}

}

这样synchronized 块包裹着,就会导致程序卡死,只要不包裹着,就可以正常运行,如下:

// 死锁,多个线程互相抱着对方需要的资源,然后形成僵持

public class DeadLock {

public static void main(String[] args) {

Makeup bestGirl = new Makeup(0, "婕儿");

Makeup betterGirl = new Makeup(1, "珂儿");

bestGirl.start();

betterGirl.start();

}

}

// 口红

class Lipstick {

}

// 镜子

class Mirror {

}

// 化妆

class Makeup extends Thread {

// 需要的资源只有一份,用static来保证只有一份

static Mirror mirror = new Mirror();

static Lipstick lipstick = new Lipstick();

int choice; // 选择

String girlName; // 使用化妆品的人

public Makeup(int choice, String girlName) {

this.choice = choice;

this.girlName = girlName;

}

@Override

public void run() {

// 化妆

try {

makeup();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

// 化妆的方法,互相持有对方的锁,就是需要拿到对方的资源

private void makeup() throws InterruptedException {

if (choice == 0) {

synchronized (lipstick) { // 获得口红的锁

System.out.println(this.girlName+"获得口红的锁");

Thread.sleep(1000);

}

synchronized (mirror) { // 一秒后想获得镜子的锁

System.out.println(this.girlName+"获得镜子的锁");

}

} else {

synchronized (mirror) { // 获得镜子的锁

System.out.println(this.girlName+"获得镜子的锁");

Thread.sleep(2000);

}

synchronized (lipstick) { // 一秒后想获得口红的锁

System.out.println(this.girlName+"获得口红的锁");

}

}

}

}

上面列出了死锁的四个条件,我们只要想办法破其中任意一个,或多个条件就可以避免死锁发生

1.这是一个线程同步问题,生产者和消费者共享同一个资源,并且生产者和消费者之间相互依赖,互为条件.

2.Java提供了几个方法解决线程之间的通信问题

3.解决方式1

并发协作模型“生产者/消费者模式” —管程法

生产者将生产好的数据放入缓冲区,消费者从缓冲区拿出数据

4.解决方式2

// 测试线程池

public class PoolTest {

public static void main(String[] args) {

// 创建服务,创建池子

// newFixedThreadPool,参数为:线程池池子大小

ExecutorService service = Executors.newFixedThreadPool(10);

service.execute(new MyThread());

service.execute(new MyThread());

service.execute(new MyThread());

service.execute(new MyThread());

// 2.关闭连接

service.shutdown();

}

}

class MyThread implements Runnable {

@Override

public void run() {

System.out.println(Thread.currentThread().getName());

}

}

曲靖java培训学校告诉你Java多线程问题总结?

Java多线程分类中写了21篇多线程的文章,21篇文章的内容很多,个人认为,学习,内容越多、越杂的知识,越需要进行深刻的总结,这样才能记忆深刻,将知识变成自己的。java课程培训机构认为这篇文章主要是对多线程的问题进行总结的,因此罗列了多个多线程的问题。

这些多线程的问题,有些来源于各大网站、有些来源于自己的思考。

(1)发挥多核CPU的优势

随着工业的进步,现在的笔记本、台式机乃至商用的应用服务器至少也都是双核的,4核、8核甚至16核的也都不少见,如果是单线程的程序,那么在双核CPU上就浪费了50%,在4核CPU上就浪费了75%。单核CPU上所谓的”多线程”那是假的多线程,同一时间处理器只会处理一段逻辑,只不过线程之间切换得比较快,看着像多个线程”同时”运行罢了。多核CPU上的多线程才是真正的多线程,它能让你的多段逻辑同时工作,多线程,可以真正发挥出多核CPU的优势来,达到充分利用CPU的目的。

(2)防止阻塞

从程序运行效率的角度来看,单核CPU不但不会发挥出多线程的优势,反而会因为在单核CPU上运行多线程导致线程上下文的切换,而降低程序整体的效率。但是单核CPU我们还是要应用多线程,就是为了防止阻塞。试想,如果单核CPU使用单线程,那么只要这个线程阻塞了,比方说远程读取某个数据吧,对端迟迟未返回又没有设置超时时间,那么你的整个程序在数据返回回来之前就停止运行了。多线程可以防止这个问题,多条线程同时运行,哪怕一条线程的代码执行读取数据阻塞,也不会影响其它任务的执行。

(3)便于建模

这是另外一个没有这么明显的优点了。假设有一个大的任务A,单线程编程,那么就要考虑很多,建立整个程序模型比较麻烦。但是如果把这个大的任务A分解成几个小任务,任务B、任务C、任务D,分别建立程序模型,并通过多线程分别运行这几个任务,那就简单很多了。