java多线程总结1

基本的线程机制

创建线程

  1. 实现Runnable接口,重写run方法,将Runnable实例传给Thread构造器
package com.alpha.concurrent.test;

public class RunnableTest implements Runnable {

    private static int taskId = 0;
    private int id = taskId++;

    public RunnableTest() {
        System.out.println("construct task:" + id);
    }

    @Override
    public void run() {
        System.out.println("task " + id + " run complete.");
    }

    public static void main(String[] args) {
        new Thread(new RunnableTest()).start();
        System.out.println("all thread has already started.");
    }
}

  1. 继承Thread,重写run方法
package com.alpha.concurrent.test;

public class ThreadTest extends Thread {
    @Override
    public void run() {
        super.run();
        System.out.println("thread run");
    }

    public static void main(String[] args) {
        new ThreadTest().start();
        System.out.println("thread has already started.");
    }
}

  1. 使用Executor,可以用Executors.newCachedThreadPool()、Executors.newFixedThreadPool(5)和Executors.newSingleThreadExecutor()创建ExecutorService实例,然后通过ExecutorService 的execute方法执行线程,这个方法接受一个Runnable作为参数。
package com.alpha.concurrent.test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class RunnableTestWithExecutor {
    private static void cachedExecute() {
        ExecutorService execute = Executors.newCachedThreadPool();
        for (int i = 0; i < 20; i++) {
            execute.execute(new RunnableTest());
        }
        execute.shutdown();
    }

    private static void fixedExecute() {
        ExecutorService execute = Executors.newFixedThreadPool(5);
        for (int i = 0; i < 20; i++) {
            execute.execute(new RunnableTest());
        }
        execute.shutdown();
    }

    private static  void singleThreadExecute() {
        ExecutorService execute = Executors.newSingleThreadExecutor();
        for (int i = 0; i < 20; i++) {
            execute.execute(new RunnableTest());
        }
        execute.shutdown();
    }

    public static void main(String[] args) {
//        cachedExecute();
        fixedExecute();
//        singleThreadExecute();
        System.out.println("all thread already started.");
    }
}

  1. 实现Callable接口,重写call方法,使用ExecutorService的submit执行,且返回一个Future<T>对象,其中泛型是call()返回的结果类型,可以使用Future的get方法获取该返回值,get方法会被阻塞直到结果准备就绪。
package com.alpha.concurrent.test;

import java.util.ArrayList;
import java.util.concurrent.*;

public class CallableTest implements Callable<String> {
    private static int taskId = 0;
    private int id = taskId++;
    private int n;

    public CallableTest(int n) {
        this.n = n;
    }

    private int fib(int n) {
        if (n < 2) return 1;
        return fib(n - 2) + fib(n - 1);
    }

    @Override
    public String call() throws Exception {
        int sum = 0;
        for (int i = 0; i < n; i++) {
            sum += fib(i + 1);
        }
        return "task " + id + ", sum: " + sum;
    }

    public static void main(String[] args) {
        ExecutorService executor = Executors.newCachedThreadPool();
        ArrayList<Future<String>> results = new ArrayList<>();

        for (int i = 0; i < 20; i++) {
            results.add(executor.submit(new CallableTest(i + 1)));
        }

        for (Future<String> future : results) {
            try {
                System.out.println(future.get());
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            } finally {
                executor.shutdown();
            }
        }
    }
}

休眠

有如下两种方式调用sleep,方式1中以毫秒为单位,而方式2使用TimeUnit类显式指定时间单位。sleep可能会抛出InterruptedException,所以要处理这个异常。

try {
    //方式1
    Thread.sleep(100);
    //方式2
    TimeUnit.MILLISECONDS.sleep(100);
} catch (InterruptedException e) {
    e.printStackTrace();
}

优先级

jdk有是个优先级,但是因为和多数操作系统没有很好的映射,因此应该选择使用下面三个:
MAX_PRIORITY、NORM_PRIORITY和NORM_PRIORITY,他们都是Thread的静态属性。
可以使用Thread的setPriority()方法设置线程优先级,如下:

Thread t = new Thread(new RunnableTest());
t.setPriority(Thread.MAX_PRIORITY);

线程调度器倾向于让优先级最高的线程先执行,最好尽量不要操作线程的优先级,让他保持默认的优先级。

让步

Thread.yield();

通知线程调度器,我的工作已经做得差不多了,你可以让别的线程使用CPU,但是不一定会被线程调度器采纳。任何重要的控制都不能依赖yield。

后台线程

通过Thread的setDaemon(true)将线程设置为后台线程。
一旦main方法执行完成后,若只有后台线程在运行,程序就会终止。
可以通过isDaemon()方法判断线程是不是后台线程。

join

如果在某个线程a上调用另一个线程b的join()方法,那么当前线程a将被挂起,知道目标线程b结束才恢复执行。

捕获异常

实现Thread.UncaughtExceptionHandler接口,并重写uncaughtException方法,调用Thread的setUncaughtExceptionHandler方法设置异常捕获:

class MyUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler {
    @Override
    public void uncaughtException(Thread t, Throwable e) {
        System.out.println("caught: " + e);
    }
}
Thread t = new Thread(new RunnableTest());
t.setUncaughtExceptionHandler(new MyUncaughtExceptionHandler());

Thread中有静态方法setDefaultUncaughtExceptionHandler(),可以使用这个方法设置默认的异常异常处理器。

共享资源

解决资源竞争

synchronized
将方法标记为synchronized防止冲突,所有对象都含有单一的锁,当在对象上调用synchronized方法时,此对象会被加锁,此时该对象上的其他synchronized方法只有等到前一个方法调用完毕并释放锁之后才能被调用。
一个线程可以多次获得对象的锁。

Brian的同步规则:
如果你正在写一个变量,它可能接下来被另一个线程读取,或者正在读取一个已经被另一个线程写过的变量,那么你必须使用同步,并且,读写线程都必须用相同的监视器锁同步。

Lock
可以创建显式的Lock对象警醒锁定和释放:

Lock lock = new ReentrantLock();
lock.lock();
try {
    i++;
} finally {
    lock.unlock();
}

可以在finally子句中重置状态或者进行清理等操作。

原子性和易变性

首先,要知道一件事,依赖于原子性是很棘手且很危险的。
原子性:不可分的操作
可视性: 某个线程所做的修改,在其他线程中可能是不可视的(例如,修改知识暂时存储在本地处理器缓存中),因此可视性就是要保证某个线程所做的修改要能被其他线程看到。
volatile:将域声明为volatile的,那么只要对这个域进行了写入,那么所有的读操作就都可以看到这个修改。volatile域会立即被写入到主存中,而服务操作就发生在主存中。
当一个值依赖于他之前的值时(例如递增一个计数器),volatile就无法工作了。使用volatile而不是synchronized的唯一安全情况是类中只有一个可变的域。

原子类

AtomicInteger、AtomicLong、AtomicReference等

临界区

有时只是希望防止多个线程同时访问方法内部的部分代码而不是防止访问整个方法,这样的代码段称作临界区。使用synchronized指定某个对象来创建临界区:

synchronized (obj) {
    i++;
}

这也被成为同步控制块,进入这段代码前,必须获得obj对象的锁,当其他线程想要访问这段代码,必须等到obj锁被释放后才能访问。
通过使用同步代码块,可以提高程序的性能。

线程本地存储

线程本地存储就是为使用相同变量的不同线程都创建存与线程内部的存储。可以有ThreadLocal来实现:

package com.alpha.concurrent.test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

class Accesser implements Runnable {
    private int id;

    public Accesser(int idn) {
        id = idn;
    }

    @Override
    public void run() {
        while (!Thread.currentThread().isInterrupted()){
            ThreadLocalTest.increment();
            System.out.println(this);
            Thread.yield();
        }
    }

    @Override
    public String toString() {
        return "#" + id + ":" + ThreadLocalTest.get();
    }
}

public class ThreadLocalTest {
    private static ThreadLocal<Integer> threadLocal = new ThreadLocal<Integer>(){
        @Override
        protected Integer initialValue() {
            return 20;
        }
    };

    public static void increment() {
        threadLocal.set(threadLocal.get() + 1);
    }
    public static int get() {
        return threadLocal.get();
    }

    public static void main(String[] args) {
        ExecutorService exec = Executors.newCachedThreadPool();
        for (int i = 0; i < 5; i++) {
            exec.execute(new Accesser(i));
        }
        try {
            TimeUnit.MILLISECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        exec.shutdownNow();
    }
}

ThreadLocal通常当作静态域存储,通过get、set读取或写入数据。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 222,729评论 6 517
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 95,226评论 3 399
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 169,461评论 0 362
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 60,135评论 1 300
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 69,130评论 6 398
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 52,736评论 1 312
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 41,179评论 3 422
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 40,124评论 0 277
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 46,657评论 1 320
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,723评论 3 342
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,872评论 1 353
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 36,533评论 5 351
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 42,213评论 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,700评论 0 25
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,819评论 1 274
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 49,304评论 3 379
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,876评论 2 361

推荐阅读更多精彩内容

  • Java-Review-Note——4.多线程 标签: JavaStudy PS:本来是分开三篇的,后来想想还是整...
    coder_pig阅读 1,655评论 2 17
  • Java多线程学习 [-] 一扩展javalangThread类 二实现javalangRunnable接口 三T...
    影驰阅读 2,966评论 1 18
  • 1.解决信号量丢失和假唤醒 public class MyWaitNotify3{ MonitorObject m...
    Q罗阅读 881评论 0 1
  • Java8张图 11、字符串不变性 12、equals()方法、hashCode()方法的区别 13、...
    Miley_MOJIE阅读 3,709评论 0 11
  • 下午,第一节课,四个男生迟迟没有来教室,2班一个,1班三个。 从上个学期开始,我带了两个班,有时,我调侃地说,我有...
    大漠长风_bc2f阅读 378评论 0 2