Mercurial > hg > Database > Alice

annotate src/alice/test/concurrent/SleepCodeSegment.java @ 276:3e0d1ac4f4a8

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Refactor iterating process with for-each sentence.
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Fri, 18 Oct 2013 01:51:15 +0900
parents 481f322b3206
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
77
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
1 package alice.test.concurrent;
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
2
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
3 import org.msgpack.type.ValueFactory;
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
4
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 import alice.codesegment.CodeSegment;
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 import alice.datasegment.CommandType;
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 import alice.datasegment.Receiver;
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
8
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
9 public class SleepCodeSegment extends CodeSegment {
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
10
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
11 public Receiver ds1 = ids.create(CommandType.TAKE);
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
12
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 private int num;
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
14
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
15 public SleepCodeSegment(int i) {
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
16 this.num = i;
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 }
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
18
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 @Override
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
20 public void run() {
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
21 try {
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 Thread.sleep(1000);
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 } catch (InterruptedException e) {
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
24 e.printStackTrace();
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
25 }
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
26 System.out.println("[CodeSegment-" + num + "] Hello, World!");
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
27
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 ods.put("local", "finish", ValueFactory.createNilValue());
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
29 }
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
30
481f322b3206 add test concurrent execution of code segment
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 }