2

Size: px

Start display at page:

Download "2"

れいなひきぎ
6 years ago
Views:

1 Yoshio Terada Java Evangelist Twitter 1

2 2

3 3

4 4

5 5

6 JDK1.0 Thread Runnable JDK1.1 J2SE J2SE 1.3 J2SE Java SE 6 JSR-166x Java SE 5 JSR-166 Concurrency Utilities

7 2011 Java SE 7 JSR-166y Fork/Join 2013 Java SE 8 JSR-166e Concurrency Utilities 7

8 class MyWebServer{! public static void main(string argv[]){! ServerSocket socket = new ServerSocket(80);! while(true){! final Socket conn = socket.accept();! Runnable r = new Runnable(){! publiv void run(){! 8 addconnqueue(conn);// サーバ処理 }};! new Thread(r).start();! }! } }!

9 Thread-1 Thread-2 Thread-3 new Thread(r).start(); Thread-n 9

10 -Xss Thread-1 Thread-1 用スタック Thread-2 Thread-2 用スタック Thread-3 Thread-3 用スタック Thread-n Thread-n 用スタックスタック 10

11 スレッドを無制限に生成する欠点 Java VM や OS に負荷スレッド生成ごとにメモリを消費スレッド生成数には上限がありコンテキストスイッチの切り替え 11

12 12

13 Java Concurrency Utilities とは並列処理の実装をかんたんに!! 13 並列処理用の簡易 API を提供スケーラビリティパフォーマンス保守性可読性の向上スレッドセーフ

14 JSR-166 で提供された機能 14 タスクの非同期実行並行コレクションロックシンクロナイザアトミック処理

15 利用可能なクラスと拡張 Executors, Thread Pool, Futures コレクション: Queues, Blocking Queues, Concurrent HashMap ロック同期: Semaphores, Barriers, Atomic変数他の拡張 15

16 public interface Executor{! void execute(runnable command);! }! 16

17 public interface ExecutorService extends Executor{! void shutdown();! List<Runnable> shutdownnow();! boolean isshutdown();! boolean isterminated();! boolean awaittermination(long timeout,! TimeUnit unit);! <T> Future<T> submit(callable<t> task)! 他! }! 17

18 static int CPU_NUM =! Runtime.getRuntime().availableProcessors();! ExecutorService pool =! Executors.newFixedThreadPool(CPU_NUM);! public static void main(string argv[]){! ServerSocket socket = new ServerSocket(80);! while(true){! final Socket conn = socket.accept();! Runnable r = new Runnable(){! public void run(){;// 何らかの処理 } };! pool.execute(r);! }}! 18

19 ExecutorService pool =! Executors.newFixedThreadPool(CPU_NUM); pool.execute(r); LinkedBlockingQueue (FIFO) T1 T2 T3 T4 ThreadFactory newfixedthreadpool Tn 19

20 Concurrency Utilities の導入効果効率的にスレッド実行が可能スレッドライフサイクル管理も可能 20

21 21

22 1998 JPE 1999 J2EE 1.2 JMS J2EE 1.4 J2EE 1.3 MDB 2006 Java EE Java EE 6 Servlet EJB 22

23 23

24 24

25 25

26 @Stateless! public class MailAddressRegisterEJB = "java:comp/jmsconfact")! ConnectionFactory = "jms/mailregistqueue")! Queue queue;! public void regist address(string address){! try(jmscontext context = conn.createcontext()){! context.createproducer().send(queue,! address);}}} 26

27 @MessageDriven(mappedName = "jms/mailregistqueue")! public class SendMessageMDB implements MessageListener! { public MailSender public void onmessage(message message) {! try {! TextMessage msg = (TextMessage) message;! mailsender.sendmessage(msg.gettext());! } catch (JMSException jmse) {! jmse.printstacktrace();! }! }} 27

28 28

29 @WebServlet(name = "MailSenderServlet", urlpatterns =! {"/MailSenderServlet"}, asyncsupported = true)! public class MailSenderServlet extends HttpServlet {! protected void processrequest(! HttpServletRequest request,! HttpServletResponse response)! throws ServletException, IOException {! AsyncContext ac = request.startasync();! ac.start(new MailSenderRunnable(ac));! }! 29

30 30

31 @Stateless! public class Sync SenderEJB MailSender mailsend;! public void syncsendmessage(string ){! mailsend.sendmessage( );! public void asyncsendmessage(string ){! mailsend.sendmessage( );! }! }! 31

32 32

33 Web/EJB コンテナ EJB JSP Servlet Java EE 関連機能 (JAX-RS,JavaMail, CDI など ) Runnable Callable 33

34 Web/EJB コンテナ EJB JSP Servlet Runnable Callable Java EE 関連機能 (JAX-RS,JavaMail, CDI など ) ManagedExecutor Service ManagedScheduledExecutorService Concurrency Utilities for EE ContextService ManagedThreadFactory 34

35 35

36 タスクを実装 A implements Runnable B implements Callable サーバ側で設定を実施デフォルト設定も利用可非同期タスクを実装リソースインジェクションでサーバ管理スレッドを利用 36

37 public class MyRunnableTask implements Runnable public void run() {! try {! Thread.sleep(10000); } catch (InterruptedException ex) {! logger.log(level.severe, null, ex);! }! }! }! 37

38 public class MyCallableTask implements! Callable<String> public String call() throws Exception {! return Hello World ;! }! }! 38

39 39

40 @Stateless! public class MyManagedExecutorService =! "concurrent/defaultmanagedexecutorservice")! ManagedExecutorService managedexecsvc;! public void execexecutorservice() {! MyRunnableTask task = new MyRunnableTask();! managedexecsvc.submit(task);! MyCallableTask singletask =! new MyCallableTask("Foo Bar");! Future<String> singlefuture =! managedexecsvc.submit(singletask);}! 40

41 41

42 タスクを実装 A implements Runnable B implements Callable サーバ側で設定を実施デフォルト設定も利用可非同期タスクを実装リソースインジェクションでサーバ管理スレッドを利用 42

43 43

44 @Stateless! public class = "concurrent/! DefaultManagedScheduledExecutorService")! ManagedScheduledExecutorService managedscheduledexecsvc;! public void execscheduledexecutorservice() {! MyRunnableTask task = new MyRunnableTask();! managedscheduledexecsvc.schedule(! task, 60L, TimeUnit.SECONDS);! }! 44

45 @Stateless! public class = "concurrent/! DefaultManagedScheduledExecutorService")! ManagedScheduledExecutorService managedscheduledexecsvc;! public void execscheduledexecutorservice() {! MyRunnableTask task = new MyRunnableTask();! managedscheduledexecsvc.schedule(! task, new MyTrigger(new Date(), 10, 1000) }! 45

46 import javax.enterprise.concurrent.trigger;! public class MyTrigger implements Trigger public Date getnextruntime(lastexecution le,! Date date){! public boolean skiprun(lastexecution le,! Date date) {! }! }! 46

47 47

48 submit() の実行 submit 成功 tasksubmitted Submitted taskstarting キャンセル中止タスクの実行準備タスク実行 taskaborted Started キャンセル中止 taskdone タスク実行完了 Done 48

49 public class MyManagedTaskListener implements! ManagedTaskListener {! public void tasksubmitted(future<?> future,! ManagedExecutorService mes, Object o) {! }! public void taskstarting(future<?> future,! ManagedExecutorService mes, Object o) {! }! public void taskaborted(future<?> future,! ManagedExecutorService mes, Object o, Throwable thrwbl){! }! public void taskdone(future<?> future,! ManagedExecutorService mes, Object o, Throwable thrwbl){! }! }! 49

50 @Resource(name = "concurrent/! MyManagedExecutorService")! ManagedExecutorService manageexecsvc;! public void invokemytasklistener() {! MyRunnableTask task = new MyRunnableTask();! MyManagedTaskListener listener =! new MyManagedTaskListener();! Runnable taskwithlistener =! ManagedExecutors.managedTask(task, listener);! manageexecsvc.execute(taskwithlistener);! }! 50

51 51

52 public class MyRunnable implements public void run() {! System.out.println( オリジナルメソッド呼び出し ");! }! } 52

53 public class MyInvocationHandler implements InvocationHandler {! private Object underlying;! public MyInvocationHandler(Object underlying) {! this.underlying = public }! Object invoke(object proxy, Method method,! Object[] args) throws Throwable {! System.out.println( オリジナルの呼び出しの前処理 ");! Object ret = method.invoke(underlying, args);! System.out.println( オリジナルの呼び出しの後処理 ");! return ret;}} 53

54 MyRunnable public class task MyDynamicProxy = new MyRunnable();! {! InvocationHandler public static void handler main(string = new! argv[]){! ここで! MyInvocationHandler(task);! Runnable }}! proxy =! (Runnable)Proxy.newProxyInstance(! MyRunnable.class.getClassLoader(),! new Class[]{Runnable.class}, handler);! ExecutorService exec =! Executors.newSingleThreadExecutor();! exec.submit(proxy); 54

55 ExecutorService exec =! Executors.newSingleThreadExecutor();! exec.submit(proxy);! 55

56 56

57 @Stateless! public class ContextServiceManager = "concurrent/defaultcontextservice")! ContextService ctxsvc;! public void execsimplecontextservice() {! ExecutorService singlethreadexecutor =! Executors.newSingleThreadExecutor(threadFactory);! MyRunnableTask task = new MyRunnableTask();! Runnable proxiedtask =! ctxsvc.createcontextualproxy(task,runnable.class);! singlethreadexecutor.submit(proxiedtask);}}! 57

58 58

59 59

60 60

61 @Resource(name = "concurrent/! DefaultManagedThreadFactory")! ManagedThreadFactory threadfactory;! public void execthreadfactory() {! MyRunnableTask task = new MyRunnableTask();! Thread taskthread =! threadfactory.newthread(task);! taskthread.start();! }! 61

62 ExecutorService threadpoolexecutor =! Executors.newFixedThreadPool(4,threadFac);! threadpoolexecutor = new ThreadPoolExecutor(4, 4,! 0L, TimeUnit.MILLISECONDS,! new LinkedBlockingQueue<Runnable>(),! threadfac);! 62 java.util.concurrent.threadpoolexecutor

63 @Resource(name = "concurrent/! DefaultManagedThreadFactory")! ManagedThreadFactory threadfactory;! public void execthreadfactory() {! MyRunnableTask task = new MyRunnableTask();! ExecutorService exec =! new ThreadPoolExecutor(4, 4,! 0L, TimeUnit.MILLISECONDS,! new LinkedBlockingQueue<Runnable>(),! threadfactory);! exec.submit(task);}! 63

64 64

65 65

66 66

67 67

68 68

Agenda SPARC Enterprise T シリーズのご紹介 Java Concurrency Utilities のご紹介 Java SE 7 新機能のご紹介まとめ 2

SPARC Enterprise T-シリーズで実力を発揮する Javaコンカレンシーユーティリティサンマイクロシステムズ株式会社 Java エバンジェリスト寺田佳央 http://blogs.sun.com/yosshi 1 Agenda SPARC Enterprise T シリーズのご紹介 Java Concurrency Utilities のご紹介 Java SE 7 新機能のご紹介