程序员旅行·在路上

Java_多线程

2019-08-18  本文已影响0人  书虫大王X

1.知识点:

1.介绍多线程
2.线程安全

2.知识点的运用:

1.多线程的作用:

image.png
image.png

3.创建线程的方式:
一般就是两种:

1)继承Thread类:定义一个继承Thread的类,在类中实现run方法
例:

//创建两个线程,任务都是打印 1 - 100
public class MyClass {
    static TestThread thread2;
    public static void main(String[] args){

        //开启任务
        TestThread thread = new TestThread();
        thread.setName("子线程1");
        thread.start();

        thread2 = new TestThread();
        thread2.setName("子线程2");
        thread2.start();
    }
}

//自定义一个类,继承Thread并实现run方法
class TestThread extends Thread{
    //实现run方法:方法里面就是具体需要执行的代码
    @Override
    public void run() {
        String name = Thread.currentThread().getName();
        for (int i = 0; i < 100; i++) {
            System.out.println(name + ":" + i + " ");
            if (this != MyClass.thread2) {
                if (i == 10) {
                    try {
                        MyClass.thread2.join();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
        super.run();
    }
}

2)实现Runnable接口,并实现run方法:

//在主函数中
//创建一个线程,任务是打印 1 - 100
        //创建一个任务:创建一个类实现Runnable接口
        yk pt = new yk();
        //使用Thread为这个任务分配线程
        Thread t = new Thread(pt);
        //开启任务
        t.start();
        t.setName("子线程1");

//创建一个类,实现Runnable接口
class yk implements Runnable{
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println(Thread.currentThread().getName() + " " +  i);
        }
    }
}

4.start()方法和run()方法的区别:

调用start()方法,不同线程的run()方法里面的代码交替执行。调用run()方法,代码是同步执行的,必须等待一个线程的run()方法里面的代码全部执行完毕之后,另外一个线程才可以执行其run()方法里面的代码。
5.什么是线程安全:
我认为:
在多线程下执行和在单线程下执行结果都是一样的,那么代码就是线程安全的。
6.如何在两个线程之间共享数据
可以通过在线程之间共享对象,然后通过wait/notify/notifyAll、await/signal/signalAll进行唤起和等待。
例:
用两个线程合作打印 0 - 100

public class MyClass {
    public static void main(String[] args){

        Ticket ticket = new Ticket("重庆");
        Thread t1 = new Thread(ticket);
        t1.start();

        Ticket ticket2 = new Ticket("上海");
        Thread t2 = new Thread(ticket2);
        t2.start();
    }
}
//创建一个类,实现Runnable接口
class Ticket implements Runnable {
    //定义所有车票的数量
    public static int num = 100;
    String name;

    public Ticket(String name) {
        this.name = name;
    }
    //创建一个共享对象
    static final Object object = new Object();
    public void run() {
        for (int i = 1; i <= 100; i++) {
            synchronized (object) {
                if (num > 0) {
                    System.out.println(name + "出票:" + num);
                    num--;
                    try {
                        // 通知其他线程执行
                        object.notify();
                        //当前线程等待
                        object.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else {
                    break;
                }
            }
        }
    }

7.sleep方法和wait方法的区别:
sleep方法和wait方法都可以用来放弃CPU一定的时间,不同点在于如果线程持有某个对象的监视器,sleep方法不会放弃这个对象的监视器,wait方法会放弃这个对象的监视器
8.synchronized和ReentrantLock:
1)synchronized是Java语言的关键字,当它用来修饰一个方法或者一个代码块的时候,能够保证在同一时刻最多只有一个线程执行该段代码。

public class Test {
  public static void main(String[] var0) {
    Counter counter = new Counter();
    // 注:myThread1 和 myThread2 是调用同一个对象 counter
    MyThread myThread1 = new MyThread(counter);
    MyThread myThread2 = new MyThread(counter);
    myThread1.start();
    myThread2.start();
  }

  private static class Counter {
    private ReentrantLock mReentrantLock = new ReentrantLock();
    public void count() {
      mReentrantLock.lock();
      try {
        for (int i = 0; i < 6; i++) {
          System.out.println(Thread.currentThread().getName() + ", i = " + i);
        }
      } finally {
          // 必须在 finally 释放锁
        mReentrantLock.unlock();
      }
    }
  }
 //定义一个类,继承Thread 
  private static class MyThread extends Thread {
    private Counter mCounter;
    public MyThread(Counter counter) {
      mCounter = counter;
    }
    @Override
    public void run() {
      super.run();
      mCounter.count();
    }
  }
}

9.常用的方法:

上一篇 下一篇

猜你喜欢

热点阅读