Feedback

src/org/kodluyoruz/Main.java

@@ -2,7 +2,37 @@
 
 public class Main {
 
+
     public static void main(String[] args) {
-	// write your code here
+       QueueProcesses<String> eleman= new QueueProcesses<>();
+        eleman.add(new String("Merhaba"));
+        eleman.add(new String("busra"));
+        eleman.add(new String("java"));
+        try{
+            System.out.println(eleman.peek());
+            System.out.println(eleman.poll());
+            System.out.println(eleman.poll());
+            System.out.println(eleman.poll());
+            System.out.println(eleman.peek());
+        }
+        catch (NullPointerException e){
+            System.out.println(e);
+        }
+
+
+        MyThread thread1 = new MyThread(eleman);
+        MyThread thread2 = new MyThread(eleman);
+
+        thread1.start();
+        thread2.start();
+
+        try {
+            thread1.join();
+            thread2.join();
+        } catch (InterruptedException e) {
+            System.out.println("Main thread is interrupted");
+        }
+
+        System.out.println("Main thread is finishing");
     }
 }

src/org/kodluyoruz/MyThread.java

@@ -0,0 +1,19 @@
+package org.kodluyoruz;
+
+public class MyThread<T> extends Thread{
+    T deger;
+    static QueueProcesses op = new QueueProcesses();
+
+    public MyThread(T deger) {
+        super();
+        this.deger = deger;
+    }
+
+    public void run() {
+        System.out.println(this.getName() + " is starting");
+        op.add(this.deger);
+       op.peek();
+       op.poll();
+        System.out.println(this.getName() + " is finishing");
+    }
+}

src/org/kodluyoruz/Node.java

@@ -0,0 +1,31 @@
+package org.kodluyoruz;
+
+public class Node <T> {
+    private T deger;
+    private Node<T> next;
+
+    public Node( T deger){
+
+        this.deger=deger;
+    }
+    public Node(T deger, Node<T> next){
+         this.deger= deger;
+         this.next= next;
+    }
+
+    public T getDeger() {
+        return deger;
+    }
+
+    public void setDeger(T deger) {
+        this.deger = deger;
+    }
+
+    public Node<T> getNext() {
+        return next;
+    }
+
+    public void setNext(Node<T> next) {
+        this.next = next;
+    }
+}

src/org/kodluyoruz/Queue.java

@@ -0,0 +1,8 @@
+package org.kodluyoruz;
+
+public interface Queue<T> {
+    void add(T deger);
+    T peek();
+    T poll();
+
+}

src/org/kodluyoruz/QueueProcesses.java

@@ -0,0 +1,48 @@
+package org.kodluyoruz;
+
+public class QueueProcesses<T> implements Queue<T>{
+    private Node<T> ilk;
+    private Node<T>son;
+
+    @Override
+    synchronized  public void add(T deger) {
+        Node<T> node = new Node<T>(deger);
+        if(ilk==null) {
+            ilk = node;
+            son = node;
+
+        }else{
+            son.setNext(node);
+            son=node;
+
+        }
+
+    }
+
+    @Override
+    synchronized  public T peek() {
+        if(ilk==null) {
+            throw new NullPointerException("Queue Bos");
+        }
+        else
+            return ilk.getDeger();
+
+
+    }
+
+    @Override
+    synchronized  public T poll() {
+
+        if(ilk==null){
+            throw new NullPointerException("Queue Bos");
+        }
+       else {
+            T deger= null;
+            Node<T> node=ilk;
+            ilk= node.getNext();
+            deger=node.getDeger();
+            return deger;
+        }
+
+    }
+}