Thread: Constructing a threaded pipeline using buffer to sort a list of integers

A thread pipeline is a sequence of threads linked together with a chain of buffers. Each thread in the pipeline reads from the buffer preceding it in the chain and may write to the buffer following it in the chain.

Your task is to construct a pipeline that will sort a list of integer values. The pipe will consist of 10 threads only. Each thread will sort its own list of values.

import java.util.*;
import java.util.concurrent.locks.*;
import java.io.*;
 
public class Pipeline{
 
	public static void main(String []args){
 
		ArrayList<Integer>buffer =new ArrayList<Integer>(10);
 
		new Thread(new Producer(buffer).      ).start();
		new Thread(new Consumer(buffer)).start();
	}
 
	}
class Producer implements Runnable{
 
	ArrayList<Integer>buffer;
	public Producer(ArrayList<Integer>k){
		buffer=k;
	}
	Scanner in= new Scanner(new File("source.txt"));
	public void run(){
		while (in.hasNextLine()) {
            String s = in.nextLine();   
 
			buffer.put(s);
			in.close();
			try{
				Thread.sleep(100);
			}catch(InterruptedException e){}
		}
	}
}
 
class Consumer implements Runnable{
	Buffer <Integer>buffer;
	public Consumer(Buffer<Integer>k){
		buffer = k;
	}
	PrintWriter out = new PrintWriter(new FileWriter("dest.txt"));                    
	public void run(){
		System.out.println ("Buffer data");
			Integer s =buffer.get();			
			System.out.println (s+" ");
			out.close();
			try{
				Thread.sleep(500);
			}catch(InterruptedException e){}
 
 
	}
}
 
 
 
 
 
 
class Buffer{
	private int x;
	private boolean item;
	private Lock lock = new ReentrantLock();
	private Condition full = lock.newCondition();
	private Condition empty = lock.newCondition();
	public Buffer(){item = false;}
	public int read(){
		lock.lock();
		try{
		  while(!item)
			 try{full.await();}
			 catch(InterruptedException e){}
		  item = false;
		  empty.signal();
		  return x;
	 }finally{lock.unlock();}
	}
	public void write(int k){
		lock.lock();
		try{
	    while(item)
		   try{empty.await();}
		   catch(InterruptedException e){}
	    x = k; item = true;
	    full.signal();
	  }finally{lock.unlock();}
  }
}

Just did that there mate

it seems to me that it is taking string and reading it into buffer then output to the consumer, i think i may have my wires crossed somewhere. I want the buffer to pass an arraylist of intergers to 10 threads each time the threads gets the list it sorts 10,000 and passes it on to the next thread to sort!!

No sorry this is all I have

thanks for your help anyways