forked from Parallele_Programmierung/Labs
Format code and clean up imports in Main classes
parent
c89682b3fb
commit
3d78c6522c
|
|
@ -1,10 +1,9 @@
|
||||||
package pp;
|
package pp;
|
||||||
|
|
||||||
import java.util.Arrays;
|
|
||||||
|
|
||||||
import akka.actor.ActorRef;
|
import akka.actor.ActorRef;
|
||||||
import akka.actor.ActorSystem;
|
import akka.actor.ActorSystem;
|
||||||
import akka.actor.Props;
|
import akka.actor.Props;
|
||||||
|
import java.util.Arrays;
|
||||||
import pp.messages.FindMsg;
|
import pp.messages.FindMsg;
|
||||||
|
|
||||||
public class Main {
|
public class Main {
|
||||||
|
|
@ -12,9 +11,13 @@ public class Main {
|
||||||
public static void main(String... args) {
|
public static void main(String... args) {
|
||||||
var system = ActorSystem.create();
|
var system = ActorSystem.create();
|
||||||
var master = system.actorOf(Props.create(MasterActor.class));
|
var master = system.actorOf(Props.create(MasterActor.class));
|
||||||
String[] files = { "src/main/resources/test1.txt", "src/main/resources/test2.txt", "src/main/resources/test3.txt", "src/main/resources/test4.txt" };
|
String[] files = {
|
||||||
|
"src/main/resources/test1.txt",
|
||||||
|
"src/main/resources/test2.txt",
|
||||||
|
"src/main/resources/test3.txt",
|
||||||
|
"src/main/resources/test4.txt",
|
||||||
|
};
|
||||||
var msg = new FindMsg(Arrays.asList(files), "Erlang");
|
var msg = new FindMsg(Arrays.asList(files), "Erlang");
|
||||||
master.tell(msg, ActorRef.noSender());
|
master.tell(msg, ActorRef.noSender());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,10 +1,9 @@
|
||||||
package pp;
|
package pp;
|
||||||
|
|
||||||
import java.util.Arrays;
|
|
||||||
|
|
||||||
import akka.actor.ActorRef;
|
import akka.actor.ActorRef;
|
||||||
import akka.actor.ActorSystem;
|
import akka.actor.ActorSystem;
|
||||||
import akka.actor.Props;
|
import akka.actor.Props;
|
||||||
|
import java.util.Arrays;
|
||||||
import pp.messages.FindMsg;
|
import pp.messages.FindMsg;
|
||||||
|
|
||||||
public class Main {
|
public class Main {
|
||||||
|
|
@ -12,9 +11,13 @@ public class Main {
|
||||||
public static void main(String... args) {
|
public static void main(String... args) {
|
||||||
var system = ActorSystem.create();
|
var system = ActorSystem.create();
|
||||||
var master = system.actorOf(Props.create(MasterActor.class));
|
var master = system.actorOf(Props.create(MasterActor.class));
|
||||||
String[] files = { "src/main/resources/test1.txt", "src/main/resources/test2.txt", "src/main/resources/test3.txt", "src/main/resources/test4.txt" };
|
String[] files = {
|
||||||
|
"src/main/resources/test1.txt",
|
||||||
|
"src/main/resources/test2.txt",
|
||||||
|
"src/main/resources/test3.txt",
|
||||||
|
"src/main/resources/test4.txt",
|
||||||
|
};
|
||||||
var msg = new FindMsg(Arrays.asList(files), "Erlang");
|
var msg = new FindMsg(Arrays.asList(files), "Erlang");
|
||||||
master.tell(msg, ActorRef.noSender());
|
master.tell(msg, ActorRef.noSender());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,10 +1,9 @@
|
||||||
package pp;
|
package pp;
|
||||||
|
|
||||||
import java.util.Arrays;
|
|
||||||
|
|
||||||
import akka.actor.ActorRef;
|
import akka.actor.ActorRef;
|
||||||
import akka.actor.ActorSystem;
|
import akka.actor.ActorSystem;
|
||||||
import akka.actor.Props;
|
import akka.actor.Props;
|
||||||
|
import java.util.Arrays;
|
||||||
import pp.messages.FindMsg;
|
import pp.messages.FindMsg;
|
||||||
|
|
||||||
public class Main {
|
public class Main {
|
||||||
|
|
@ -12,12 +11,17 @@ public class Main {
|
||||||
public static void main(String... args) {
|
public static void main(String... args) {
|
||||||
var system = ActorSystem.create();
|
var system = ActorSystem.create();
|
||||||
var master = system.actorOf(Props.create(MasterActor.class));
|
var master = system.actorOf(Props.create(MasterActor.class));
|
||||||
String[] files = { "src/main/resources/test1.txt", "src/main/resources/test2.txt", "src/main/resources/test3.txt",
|
String[] files = {
|
||||||
|
"src/main/resources/test1.txt",
|
||||||
|
"src/main/resources/test2.txt",
|
||||||
|
"src/main/resources/test3.txt",
|
||||||
"src/main/resources/test4.txt",
|
"src/main/resources/test4.txt",
|
||||||
"src/main/resources/test5.txt", "src/main/resources/test6.txt", "src/main/resources/test7.txt",
|
"src/main/resources/test5.txt",
|
||||||
"src/main/resources/test8.txt" };
|
"src/main/resources/test6.txt",
|
||||||
|
"src/main/resources/test7.txt",
|
||||||
|
"src/main/resources/test8.txt",
|
||||||
|
};
|
||||||
var msg = new FindMsg(Arrays.asList(files), "Erlang");
|
var msg = new FindMsg(Arrays.asList(files), "Erlang");
|
||||||
master.tell(msg, ActorRef.noSender());
|
master.tell(msg, ActorRef.noSender());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,10 +1,9 @@
|
||||||
package pp;
|
package pp;
|
||||||
|
|
||||||
import java.util.Arrays;
|
|
||||||
|
|
||||||
import akka.actor.ActorRef;
|
import akka.actor.ActorRef;
|
||||||
import akka.actor.ActorSystem;
|
import akka.actor.ActorSystem;
|
||||||
import akka.actor.Props;
|
import akka.actor.Props;
|
||||||
|
import java.util.Arrays;
|
||||||
import pp.messages.FindMsg;
|
import pp.messages.FindMsg;
|
||||||
|
|
||||||
public class Main {
|
public class Main {
|
||||||
|
|
@ -12,12 +11,17 @@ public class Main {
|
||||||
public static void main(String... args) {
|
public static void main(String... args) {
|
||||||
var system = ActorSystem.create();
|
var system = ActorSystem.create();
|
||||||
var master = system.actorOf(Props.create(MasterActor.class));
|
var master = system.actorOf(Props.create(MasterActor.class));
|
||||||
String[] files = { "src/main/resources/test1.txt", "src/main/resources/test2.txt", "src/main/resources/test3.txt",
|
String[] files = {
|
||||||
|
"src/main/resources/test1.txt",
|
||||||
|
"src/main/resources/test2.txt",
|
||||||
|
"src/main/resources/test3.txt",
|
||||||
"src/main/resources/test4.txt",
|
"src/main/resources/test4.txt",
|
||||||
"src/main/resources/test5.txt", "src/main/resources/test6.txt", "src/main/resources/test7.txt",
|
"src/main/resources/test5.txt",
|
||||||
"src/main/resources/test8.txt" };
|
"src/main/resources/test6.txt",
|
||||||
|
"src/main/resources/test7.txt",
|
||||||
|
"src/main/resources/test8.txt",
|
||||||
|
};
|
||||||
var msg = new FindMsg(Arrays.asList(files), "Erlang");
|
var msg = new FindMsg(Arrays.asList(files), "Erlang");
|
||||||
master.tell(msg, ActorRef.noSender());
|
master.tell(msg, ActorRef.noSender());
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue