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编程的区别
- 对于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. 发送消息的方式
注意:Future表示一个异步操作的结果状态,可能还没有实际完成的异步任务的结果;Any是所有类的超类,Future[Any]的泛型是异步操作结果的类型。