source: src/main/java/bargainingchips/players/Buyer.java@ 341

package bargainingchips.players;

import java.util.List;

import java.util.ArrayList;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

import bargainingchips.NegotiationContext;
import bargainingchips.actions.Offer;
import bargainingchips.actions.OfferBy;
import bargainingchips.messaging.coordination.CoordinationMessage;
import bargainingchips.messaging.status.StatusMessage;
import bargainingchips.protocol.AsynchronousOffersProtocol;
import bargainingchips.utilityfunctions.UF_CloseToQuantity;
import bargainingchips.utilityfunctions.UtilityFunction;
import bargainingchips.wishlist.WishList;
import bargainingchips.wishlist.WishListBuilder;

public class Buyer 
{
        private Coordinator c;
        private BlockingQueue<CoordinationMessage> cin;
        private BlockingQueue<StatusMessage> cout;
        
        private List<NegotiationThread> threads;
        
        public Buyer(WishList overallWishlist) 
        {
                cin = new LinkedBlockingQueue<CoordinationMessage>();
                cout = new LinkedBlockingQueue<StatusMessage>();                
                
                // Coordinator
                c = new Coordinator(overallWishlist, cout, cin);
                
                threads = new ArrayList<NegotiationThread>();
        }
        
        public void connectSeller(String sellerName, WishList wishlistSam)
        {
                // Set up the protocol
                BlockingQueue<OfferBy> from  = new LinkedBlockingQueue<OfferBy>();
                BlockingQueue<Offer> toBuyer = new LinkedBlockingQueue<Offer>();
                BlockingQueue<Offer> toSeller = new LinkedBlockingQueue<Offer>();

                String bobiName         = "Bob" + " " + getThreadNumber();

                AsynchronousOffersProtocol aop = new AsynchronousOffersProtocol(from, bobiName, toBuyer, sellerName, toSeller);

                NegotiationContext context = new NegotiationContext();
                
                // Make a new subnegotiator
                WishList wishlist               = new WishListBuilder().addWish("Green", 2).build();
                UtilityFunction u               = new UF_CloseToQuantity(wishlist);
                Agent bobi                              = new BoulwareAgent(bobiName, u, context, toBuyer, from, cin, cout);
                
                // Seller
                UtilityFunction uSam    = new UF_CloseToQuantity(wishlistSam);
                Agent sam                               = new BasicAgent(sellerName, uSam, context, toSeller, from);
                
                // The thread
                NegotiationThread thread = new NegotiationThread();
                thread.protocol = aop;
                thread.subbuyer = bobi;
                thread.seller = sam;
                
                threads.add(thread);
        }
        
        public void startThreads()
        {
                // Start the coordinator once
                Thread threadCoordinator = new Thread(c);
                threadCoordinator.start();
                
                // Start all threads: subnegotiator + protocol + seller
                for (NegotiationThread t : threads)
                {
                        System.out.println(t.subbuyer.toDescription());
                        System.out.println("playing vs");
                        System.out.println(t.seller.toDescription());

                        Thread aopThread = new Thread(t.protocol);
                        aopThread.start();

                        Thread threadBuyer = new Thread(t.subbuyer);
                        threadBuyer.start();

                        Thread threadSeller = new Thread(t.seller);
                        threadSeller.start();
                }

        }
        
        private int getThreadNumber()
        {
                return threads.size();
        }

}