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

深藏阁楼爱情的钟 2022-01-30 19:34 242阅读 0赞

# 前言 #

**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编程的区别 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY0MTkwOQ_size_16_color_FFFFFF_t_70]

*  对于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. 发送消息的方式 #

![在这里插入图片描述][20190520110002874.png]  
**注意：Future表示一个异步操作的结果状态，可能还没有实际完成的异步任务的结果；Any是所有类的超类，Future\[Any\]的泛型是异步操作结果的类型。**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY0MTkwOQ_size_16_color_FFFFFF_t_70]: /images/20220130/7311d121b7f84fe49e8a4974121019d5.png
[20190520110002874.png]: /images/20220130/487a8b1037c64e32a5866aa089896483.png