Rev | Line | |
---|
[273] | 1 | package onetomany.bargainingchipsgame.players;
|
---|
| 2 |
|
---|
| 3 | import java.util.concurrent.BlockingQueue;
|
---|
| 4 |
|
---|
| 5 | import onetomany.bargainingchipsgame.interactions.Offer;
|
---|
| 6 |
|
---|
| 7 | public class Seller extends BilateralAgent
|
---|
| 8 | {
|
---|
| 9 | int k;
|
---|
| 10 |
|
---|
| 11 | public Seller(String name, BlockingQueue<Offer> in, BlockingQueue<Offer> out)
|
---|
| 12 | {
|
---|
| 13 | super(name, in, out);
|
---|
| 14 | k = 1;
|
---|
| 15 | }
|
---|
[278] | 16 |
|
---|
| 17 | @Override
|
---|
| 18 | public void run()
|
---|
| 19 | {
|
---|
| 20 | while (true)
|
---|
| 21 | {
|
---|
| 22 | Offer o;
|
---|
| 23 | try
|
---|
| 24 | {
|
---|
| 25 | // Wait for incoming offer
|
---|
| 26 | o = in.take();
|
---|
| 27 | receiveOffer(o);
|
---|
| 28 | Offer sendOffer = sendOffer();
|
---|
| 29 | out.put(sendOffer);
|
---|
| 30 | }
|
---|
| 31 | catch (InterruptedException e) {
|
---|
| 32 | e.printStackTrace();
|
---|
| 33 | }
|
---|
| 34 | }
|
---|
| 35 | }
|
---|
[273] | 36 |
|
---|
| 37 | @Override
|
---|
[278] | 38 | protected void receiveOffer(Offer o)
|
---|
[273] | 39 | {
|
---|
[278] | 40 | System.out.println(this + " received " + o);
|
---|
[273] | 41 |
|
---|
| 42 | }
|
---|
| 43 |
|
---|
| 44 | @Override
|
---|
| 45 | protected Offer sendOffer()
|
---|
| 46 | {
|
---|
[274] | 47 | Offer sampleOffer = Offer.getSampleOffer("Green", k);
|
---|
[273] | 48 | k++;
|
---|
| 49 |
|
---|
| 50 | System.out.println(this + " is sending " + sampleOffer);
|
---|
| 51 | return sampleOffer;
|
---|
| 52 | }
|
---|
| 53 |
|
---|
[274] | 54 | @Override
|
---|
| 55 | protected Offer sendOpeningOffer()
|
---|
| 56 | {
|
---|
| 57 | return null;
|
---|
| 58 | }
|
---|
[273] | 59 |
|
---|
| 60 |
|
---|
| 61 |
|
---|
| 62 | }
|
---|
Note:
See
TracBrowser
for help on using the repository browser.