source: src/main/java/onetomany/bargainingchipsgame/players/BuyerSubnegotiator.java@ 279

package onetomany.bargainingchipsgame.players;

import java.util.concurrent.BlockingQueue;

import onetomany.bargainingchipsgame.interactions.Offer;
import onetomany.bargainingchipsgame.players.utilityfunction.UtilityFunction;

public class BuyerSubnegotiator extends BilateralAgent
{
        // Messaging from and to the coordinator
        protected BlockingQueue<CoordinationMessage> cin;
        protected BlockingQueue<NegotiationStatusMessage> cout;
        private UtilityFunction u;
        
        int k;
        
        public BuyerSubnegotiator(String name, BlockingQueue<Offer> in, BlockingQueue<Offer> out,
                        BlockingQueue<CoordinationMessage> cin, BlockingQueue<NegotiationStatusMessage> cout) 
        {
                super(name, in, out);
                this.cin  = cin;
                this.cout = cout;
                k = 1;
        }
        
        @Override
        public void run() 
        {
                // The buyer expects a utility function from the Coordinator
                CoordinationMessage coordinatormsg = null;
                try {
                        coordinatormsg = cin.take();
                        receiveCoordinationMessage(coordinatormsg);
                } catch (InterruptedException e2) {
                        e2.printStackTrace();
                }
                
                // The buyer may send an opening offer
                Offer opening = sendOpeningOffer();
                if (opening != null)
                        try {
                                out.put(opening);
                        } catch (InterruptedException e1) {
                                e1.printStackTrace();
                        }
                
                while (true)
                {
                        Offer o;
                        try 
                        {
                                // Wait for either a message from coordinator or an incoming offer from seller
                                while (true)
                                {
                                        CoordinationMessage cpoll = cin.poll();
                                        if (cpoll != null)
                                        {
                                                receiveCoordinationMessage(cpoll);
                                                break;
                                        }
                                        
                                        Offer poll = in.poll();
                                        if (poll != null)
                                        {
                                                receiveOffer(poll);
                                                break;
                                        }
                                }
                                
                                // A sync happened, so we can send out a new offer
                                Offer sendOffer = sendOffer();
                                out.put(sendOffer);
                        } 
                        catch (InterruptedException e) {
                                e.printStackTrace();
                        }
                }
        }

        private void receiveCoordinationMessage(CoordinationMessage cpoll) 
        {
                // Update the utility function
                u = cpoll.f;            
                System.out.println(this + " received coordination msg " + cpoll);
        }

        @Override
        protected void receiveOffer(Offer o) 
        {
                System.out.println(this + " received " + o);
                
        }

        @Override
        protected Offer sendOffer()
        {
                Offer sampleOffer = Offer.getSampleOffer(k);
                k++;
                
                if (k > 5)
                        try {
                                Thread.sleep(5000);
                        } catch (InterruptedException e) {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                        }
                
                System.out.println(this + " sends " + sampleOffer);
                return sampleOffer;
        }
        
        @Override
        protected Offer sendOpeningOffer() 
        {
                Offer sampleOffer = Offer.getSampleOffer(0);
                System.out.println(this + " sends opening offer " + sampleOffer);
                return sampleOffer;
        }

}