source: src/main/java/onetomany/bargainingchipsgame/players/Coordinator.java@ 290

package onetomany.bargainingchipsgame.players;

import java.util.concurrent.BlockingQueue;

import onetomany.bargainingchipsgame.WishList;
import onetomany.bargainingchipsgame.players.utilityfunction.UF_IWantColorAndQuantity;

/**
 * Coordinates all bilateral threads.
 * The coordinator monitors and synchronizes all bilateral negotiation threads 
 * of each negotiator agent with an opponent regarding the whole preference list of the user.
 */
public class Coordinator implements Runnable
{
        // Messages coming in and out of the coordinator
        protected BlockingQueue<NegotiationStatusMessage> cin;
        protected BlockingQueue<CoordinationMessage> cout;
        /** The fixed, initial wish list that should be obtained overall */
        private WishList overallWishList;
        
        public Coordinator(WishList wishlist, BlockingQueue<NegotiationStatusMessage> negotiationMsg,
                        BlockingQueue<CoordinationMessage> coordinationMsg) 
        {
                this.overallWishList = wishlist;
                cin = negotiationMsg;
                cout = coordinationMsg;
        }

        @Override
        public void run() 
        {
                // Send a very simple coordination message to Bob_i after a while
                try {
                        Thread.sleep(2000);
                        
                        CoordinationMessage coordinationMessage2 = new CoordinationMessage();
                        coordinationMessage2.f = new UF_IWantColorAndQuantity("Green", 7);
                        cout.put(coordinationMessage2);
                        
                } catch (InterruptedException e) {
                        e.printStackTrace();
                }
                
        }

}