matsu-chara

package scalaworld.macros

import scala.collection.immutable.Seq
import scala.meta._

/**
  * <s>コンパニオンオブジェクト</s> case classにつけるアノテーション。
  * 対応するcase classのフィールドを取得し、
  * def フィールド名(value: フィールドの型): (String, フィールドの型) = (フィールド名, value)
  * というメソッドをフィールドの数だけコンパニオンオブジェクトに生成する。

matsu-chara

import java.nio.ByteBuffer
import java.security.MessageDigest

def md5(s: String) = {
  MessageDigest.getInstance("MD5").digest(s.getBytes)
}

def hashes(e: String): Seq[Long] = {
  val h1 = ByteBuffer.wrap(md5(e).splitAt(8)._1).getLong
  val h2 = ByteBuffer.wrap(md5(e).splitAt(8)._1).getLong

matsu-chara

showMessageOnBuildFilesChanged

matsu-chara

共変・反変があるとどう嬉しいのか考えるコーナー

考える際の土台として、以下のようなクラスを考えます。

class Person(val name: String)
class Teacher(override val name: String, val kamoku: String) extends Person(name)

また 文字列からクラスAのインスタンスを生成する Read[A] とクラスAのインスタンスから文字列を生成する Write[A] というクラスについて考えてみます。(ReadはfromJson、WriteはtoJsonのようなイメージです。）

matsu-chara

~sand/aaa $ ansible-playbook site.yml --connection=local
 [WARNING]: Host file not found: /etc/ansible/hosts

 [WARNING]: provided hosts list is empty, only localhost is available


PLAY [127.0.0.1] ***************************************************************

TASK [setup] *******************************************************************
ok: [127.0.0.1]

matsu-chara

---

- hosts: all
  tasks:
    - set_fact:
        mofu:
          - a
          - b
          - c
    - set_fact:

matsu-chara

package com.example

import akka.actor.Actor.Receive
import akka.actor.SupervisorStrategy.Restart
import akka.actor.{Actor, ActorSystem, FSM, Kill, OneForOneStrategy, Props, SupervisorStrategy}

import scala.concurrent.duration._

object FSMMain extends App {
  val system = ActorSystem("MyActorSystem")

matsu-chara

import akka.actor.{Actor, ActorSystem, Props}
import scala.concurrent.{blocking, Future}

object OOM extends App {
  val system = ActorSystem()
  val actor = system.actorOf(Props[OOMActor])
  (1 to 10000).foreach(actor ! _)
  Thread.sleep(10000)
  system.terminate()
}

matsu-chara

import java.util.concurrent.{ForkJoinPool, ForkJoinWorkerThread, ThreadFactory}

import scala.concurrent.{BlockContext, CanAwait, ExecutionContext}

class ThreadPrinter extends Runnable {
  override def run(): Unit = {
    println(Thread.currentThread())
    println("isDaemon: " + Thread.currentThread().isDaemon)
    println("isInstanceOfBlockingContext: " + Thread.currentThread().isInstanceOf[BlockContext])
    println("")

matsu-chara

package ex2

import akka.actor.SupervisorStrategy._
import akka.actor._

import scala.concurrent.Await
import scala.concurrent.duration.Duration

object Main1 extends App {
  val system = ActorSystem()