Анна Власова, 496: Threads + CQL + CQLex + TwitterStream + ModuleTests

projects/annnvl/.gitignore

@@ -0,0 +1 @@
+twitter4j.properties

projects/annnvl/pom.xml

@@ -0,0 +1,59 @@
+<?xml version="1.0"?>
+<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>ru.mipt.diht.students</groupId>
+    <artifactId>parent</artifactId>
+    <version>1.0-SNAPSHOT</version>
+  </parent>
+  <groupId>ru.mipt.diht.students</groupId>
+  <artifactId>annnvl</artifactId>
+  <version>1.0-SNAPSHOT</version>
+  <name>annnvl</name>
+  <url>http://maven.apache.org</url>
+  <properties>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+  </properties>
+  <dependencies>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>3.8.1</version>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.twitter4j</groupId>
+      <artifactId>twitter4j-stream</artifactId>
+      <version>4.0.4</version>
+    </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <version>1.10.19</version>
+      <scope>test</scope>
+    </dependency>
+
+    <dependency>
+      <groupId>org.hamcrest</groupId>
+      <artifactId>hamcrest-junit</artifactId>
+      <version>2.0.0.0</version>
+    </dependency>
+
+    <dependency>
+      <groupId>com.google.code.geocoder-java</groupId>
+      <artifactId>geocoder-java</artifactId>
+      <version>0.16</version>
+    </dependency>
+    <dependency>
+      <groupId>com.google.maps</groupId>
+      <artifactId>google-maps-services</artifactId>
+      <version>0.1.7</version>
+    </dependency>
+    <dependency>
+      <groupId>com.beust</groupId>
+      <artifactId>jcommander</artifactId>
+      <version>1.48</version>
+    </dependency>
+  </dependencies>
+</project>

projects/annnvl/src/main/java/ru/mipt/diht/students/annnvl/Threads/BlockingQueue/BlockingQueue.java

@@ -0,0 +1,63 @@
+package ru.mipt.diht.students.annnvl.Threads.BlockingQueue;
+
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Queue;
+
+public class BlockingQueue<T> {
+    private final int maxQueueSize;
+    private Queue<T> data;
+
+    BlockingQueue(int size) {
+        maxQueueSize = size;
+        data = new LinkedList<T>();
+    }
+
+    public final int size() {
+        return data.size();
+    }
+
+    synchronized void offer(List<T> e) {
+        while (data.size() + e.size() > maxQueueSize) {
+            Thread.yield();
+        }
+        data.addAll(e);
+    }
+
+    synchronized void offer(List<T> e, long timeout) {
+        timeout += System.currentTimeMillis();
+        while ((data.size() + e.size() > maxQueueSize) && (timeout - System.currentTimeMillis()) > 0) {
+            Thread.yield();
+        }
+        if (timeout > 0) {
+            data.addAll(e);
+        }
+    }
+
+    synchronized List<T> take(int n) {
+        while (data.size() < n) {
+            Thread.yield();
+        }
+        List<T> answer = new ArrayList<T>();
+        for (int i = 0; i < n; i++) {
+            answer.add(data.remove());
+        }
+        return answer;
+    }
+
+    synchronized List<T> take(int n, long timeout) {
+        timeout += System.currentTimeMillis();
+        while ((data.size() < n) && (timeout - System.currentTimeMillis()) > 0) {
+            Thread.yield();
+        }
+        if (timeout > 0) {
+            List<T> answer = new ArrayList<T>();
+            for (int i = 0; i < n; i++) {
+                answer.add(data.remove());
+            }
+            return answer;
+        }
+        return null;
+    }
+}

projects/annnvl/src/main/java/ru/mipt/diht/students/annnvl/Threads/Counter/CountedThread.java

@@ -0,0 +1,26 @@
+package ru.mipt.diht.students.annnvl.Threads.Counter;
+
+public class CountedThread extends Thread {
+    private static int numberOfThreads;
+    private static volatile int currentThread = 0;
+    private final int myNumber;
+
+    CountedThread(int mynum) {
+        myNumber = mynum;
+    }
+
+    public static void setNumberOfThreads(int num) {
+        numberOfThreads = num;
+    }
+
+    @Override
+    public final void run() {
+        while (true) {
+            while (myNumber != currentThread) {
+                Thread.yield();
+            }
+            System.out.println("Thread-" + (myNumber + 1) + "\n");
+            currentThread = (currentThread + 1) % numberOfThreads;
+        }
+    }
+}

projects/annnvl/src/main/java/ru/mipt/diht/students/annnvl/Threads/Counter/Counter.java

@@ -0,0 +1,14 @@
+package ru.mipt.diht.students.annnvl.Threads.Counter;
+
+public class Counter {
+    public static void main(String[] args) {
+        if (args.length < 1) {
+            throw new IllegalArgumentException("Please type number of threads");
+        }
+        int threads = Integer.parseInt(args[0]);
+        CountedThread.setNumberOfThreads(threads);
+        for (int i = 0; i < threads; i++) {
+            (new CountedThread(i)).start();
+        }
+    }
+}

projects/annnvl/src/main/java/ru/mipt/diht/students/annnvl/Threads/RollCall/RollCall.java

@@ -0,0 +1,27 @@
+package ru.mipt.diht.students.annnvl.Threads.RollCall;
+
+public class RollCall {
+    public static void main(String[] args) {
+        if (args.length < 1) {
+            throw new IllegalArgumentException("Please type number of threads");
+        }
+        int threads = Integer.parseInt(args[0]);
+        RollCallerThread.setNumberOfThreads(threads);
+        for (int i = 0; i < threads; i++) {
+            (new RollCallerThread()).start();
+        }
+        while (true) {
+            RollCallerThread.makeEverybodyOk();
+            System.out.println("Are you ready?\n");
+            RollCallerThread.nextRollCall();
+            while (!RollCallerThread.everybodyasked()) {
+                Thread.yield();
+            }
+            if (RollCallerThread.isEverybodyOk()) {
+                RollCallerThread.yes();
+                RollCallerThread.nextRollCall();
+                return;
+            }
+        }
+    }
+}

projects/annnvl/src/main/java/ru/mipt/diht/students/annnvl/Threads/RollCall/RollCallerThread.java

@@ -0,0 +1,67 @@
+package ru.mipt.diht.students.annnvl.Threads.RollCall;
+
+import java.util.Random;
+
+public class RollCallerThread extends Thread {
+    private static final int HUNDREED = 100;
+    private static final double LOWERBOUND = 0.1;
+    private static int numberOfThreads;
+    private static volatile int asked = 0;
+    private static volatile int timesShouldBe = -1; //какой раз мы проводим опрос
+    private static boolean yes4all = false;
+    private static boolean everybodyOk = true;
+    private Random rand;
+    private int timesNum; //какой раз мы вызываем конкретный процесс
+
+    RollCallerThread() {
+        rand = new Random(HUNDREED);
+        timesNum = 0;
+    }
+
+    public static void setNumberOfThreads(int num) {
+        numberOfThreads = num;
+    }
+
+    public static void yes() {
+        yes4all = true;
+    }
+
+    public static boolean isEverybodyOk() {
+        return everybodyOk;
+    }
+
+    public static void makeEverybodyOk() {
+        everybodyOk = true;
+    }
+
+    public static void nextRollCall() {
+        timesShouldBe++;
+        asked = 0;
+    }
+
+    public static boolean everybodyasked() {
+        return (asked == numberOfThreads);
+    }
+
+    @Override
+    public final void run() {
+        while (true) {
+            synchronized (this) {
+                while (timesNum != timesShouldBe) {
+                    Thread.yield();
+                }
+                if (yes4all) {
+                    return;
+                }
+                timesNum++;
+                if (rand.nextDouble() < LOWERBOUND) {
+                    System.out.println("No\n");
+                    everybodyOk = false;
+                } else {
+                    System.out.println("Yes\n");
+                }
+                asked++;
+            }
+        }
+    }
+}

projects/pom.xml

@@ -1,11 +1,12 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
 
-    <groupId>ru.mipt.diht.students</groupId>
-    <artifactId>parent</artifactId>
-    <version>1.0-SNAPSHOT</version>
-    <packaging>pom</packaging>
+     <groupId>ru.mipt.diht.students</groupId>
+     <artifactId>parent</artifactId>
+     <version>1.0-SNAPSHOT</version>
+
+     <packaging>pom</packaging>
 
     <name>fizteh-java-2015</name>
     <url>https://github.com/KhurtinDN/fizteh-java-2015</url>
@@ -28,8 +29,9 @@
 
     <modules>
         <module>dkhurtin</module>
-        <!--Add you module here-->
-    </modules>
+        <module>annnvl</module>
+	<!--Add you module here-->
+  </modules>
 
     <dependencyManagement>
         <dependencies>
@@ -131,4 +133,4 @@
         </plugins>
     </build>
 
-</project>
+</project>