Scala Actor并发编程、什么是Scala Actor、java并发编程与Scala Actor编程的区别、Java创建线程的4种方法、Actor的执行顺序、Actor发送消息的方式 18

前言

Scala Actor是scala 2.10.x版本及以前的版本的Actor,Scala在2.11.x版本中将Akka加入其中,作为其默认的Actor,老版本的Actor已经废弃。

1. 什么是Scala Actor

  • Scala中的Actor能够实现并行编程的强大功能,它是基于事件模型的并发机制,Scala是运用消息的发送、接收来实现高并发的。
  • Actor可以看做是一个个独立的实体,他们之间是毫无关联的。但是,他们可以通过消息来通信。一个Actor收到其他Actor的消息后,它可以根据需要作出各种响应。消息的类型可以是任意的,消息的内容也可以是任意的。

2. Java并发编程与Scala Actor编程的区别

Scala Actor并发编程、什么是Scala Actor、java并发编程与Scala Actor编程的区别、Java创建线程的4种方法、Actor的执行顺序、Actor发送消息的方式 18

  • 对于Java,我们都知道它的多线程实现需要对共享资源(变量、对象等)使用synchronized关键字进行代码块同步、对象锁互斥等等。而且,常常一大块的try…catch语句块中加上wait方法、notify方法、notifyAll方法是让人很头疼的。
  • 如上所述令人头疼的原因,就在于Java中多数使用的是可变状态的对象资源,对这些资源进行共享来实现多线程编程的话,控制好资源竞争与防治对象状态被意外修改时非常重要的,而对象状态的不变形也是较难以保证的。
  • 与Java的基于共享数据和锁的线程模式不同,Scala的Actor包则提供了另外一种不共享任何数据、依赖消息传递的模型,从而进行并发编程。

3. Java创建线程的4种方法

// 1 继承Thread 
public class Thread1 extends Thread {
    @Override
    public void run() {//act
        for (int i = 0; i < 100; i++) {
            System.out.println(i);
        }
    }
    public static void main(String[] args) {
        Thread1 thread1 = new Thread1();
        thread1.start();
    }
}
/**
 * 实现线程的第二种方法:实现Runnable
 */
public class Thread2 implements Runnable {
    @Override
    public void run() {
    }
    public static void main(String[] args) {
        Thread thread = new Thread(new Thread2());
        thread.start();
    }
}
/**
 * 实现线程的第三种方式:实现Callable<String>
 *     区别:与继承Thread和实现Runnable的区别:
 *      有返回值
 */
public class Thread3 implements Callable<Integer> {
    @Override
    public Integer call() throws Exception {
        return null;
    }
}
/**
 * 实现线程的第四种方式:线程池
 */
public class Thread4 {
    public static void main(String[] args) {
        //创建固定5线程的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(5);
        ExecutorService executorService1 = Executors.newCachedThreadPool();
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5);
        ExecutorService executorService2 = Executors.newSingleThreadExecutor();
        ScheduledExecutorService scheduledExecutorService1 = Executors.newSingleThreadScheduledExecutor();
        ExecutorService executorService3 = Executors.newWorkStealingPool();
    }
}

4. Actor的执行顺序

  • 首先调用start()方法启动Actor
  • 调用start()方法后其act()方法会被执行
  • Actor发送消息
  • act方法执行完成之后,程序会调用exit方法

5. 发送消息的方式

Scala Actor并发编程、什么是Scala Actor、java并发编程与Scala Actor编程的区别、Java创建线程的4种方法、Actor的执行顺序、Actor发送消息的方式 18
注意:Future表示一个异步操作的结果状态,可能还没有实际完成的异步任务的结果;Any是所有类的超类,Future[Any]的泛型是异步操作结果的类型。