source: src/main/java/onetomany/bargainingchipsgame/players/BilateralAgent.java@ 277

package onetomany.bargainingchipsgame.players;

import java.util.concurrent.BlockingQueue;

import onetomany.bargainingchipsgame.Bundle;
import onetomany.bargainingchipsgame.interactions.Offer;

public abstract class BilateralAgent implements Runnable
{
        String name;
        BlockingQueue<Offer> in;
        BlockingQueue<Offer> out;
        
        protected abstract void receiveOffer(Bundle bundle);
        
        protected abstract Offer sendOffer();
        
        protected abstract Offer sendOpeningOffer();
        
        public BilateralAgent(String name, BlockingQueue<Offer> in, BlockingQueue<Offer> out) 
        {
                super();
                this.name = name;
                this.in = in;
                this.out = out;         
        }

        @Override
        public void run() 
        {
                Offer opening = sendOpeningOffer();
                if (opening != null)
                        try {
                                out.put(opening);
                        } catch (InterruptedException e1) {
                                // TODO Auto-generated catch block
                                e1.printStackTrace();
                        }
                
                while (true)
                {
                        Offer o;
                        try 
                        {
                                // Wait for incoming offer
                                o = in.take();
                                Bundle bundle = o.getBundle();
                                receiveOffer(bundle);
                                Offer sendOffer = sendOffer();
                                out.put(sendOffer);
                        } 
                        catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                }
        }

        

        @Override
        public String toString() 
        {
                return name;
        }

}