Синхронизация потоков.

@isakz · Регистрация: 23.10.2010

Студворк — интернет-сервис помощи студентам

имеется магазин и две группы постовщиков, товары будут поставлять две группы одновременно. Если магазин заполняется товаром, то происходит приостановка поставок. После продажи какого-либо количество товаров, снова возабновляются поставки. Что то так вот.

@andrewkjr · 29.11.2010, 20:50

да, я с вами согласен...

@isakz · 29.11.2010, 20:51 **[ТС]**

скучно что ли стало совсем))

@andrewkjr · 29.11.2010, 21:43

та есть малёхо ))

Ну так есть наработки? Вышеописаный процес легко(ну не тривиально) реализуется с помощью wait / notify методов жава потоков... надо просто что начать делать .. )

@isakz · 29.11.2010, 22:01 **[ТС]**

да тут потихоньку изучаю wait notify, но пока не сообразил как их использовать в этом примере

@andrewkjr · 29.11.2010, 23:44

Product.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
package org.goodsmarket;
 
public class Product {
    private double price = 0.0d;
    private String name = null;
    
    public Product(String name, double price) {
        this.name = name;
        this.price = price;
    }
    
    public double getPrice() {
        return price;
    }
    public void setPrice(double price) {
        this.price = price;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
}

Supplier.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
package org.goodsmarket;
 
public class Supplier implements Runnable{
    
    String name = null;
    Store store = null;
    
    public Supplier(String name, Store store) {
        this.name = name;
        this.store = store;
    }
    
    @Override
    public void run() {
        supplyProducts(store);
    }
    
    private void supplyProducts(Store store) {
        long c = 0;
        while(true) {
            //sleep
            try { Thread.sleep(500); }
            catch (InterruptedException e) { e.printStackTrace(); }
            
            Product newproduct = new Product(name+" | "+c++, 5.0);
            store.takeProduct(newproduct);
        }
    }
    
}

Customer.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
package org.goodsmarket;
 
public class Customer implements Runnable {
    
    private Store store = null;
    private String name = null;
    
    public Customer(String name, Store store) {
        this.name = name;
        this.store = store;
    }
    
    private void buyProduct(Store store) {
        while(true) {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        store.saleProduct();
        }
    }
 
    @Override
    public void run() {
        buyProduct(store);
    }
}

Store.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
package org.goodsmarket;
 
import java.util.ArrayList;
import java.util.List;
 
public class Store {
    
    // available products on Store
    List<Product> products = new ArrayList<Product>();
    
    // total revenue
    double revenue = 0.0;
 
    public synchronized void takeProduct(Product product) {
        if(products.size() > 20) {
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
        products.add(product);
        
        System.out.println("take product ("+products.size()+")");
    }
 
    public synchronized void saleProduct() {
        
        if(products.size()>0) {
            revenue += products.get(0).getPrice();
            products.remove(0);
        }
        System.out.println("STORE: sale product       products in store: "+products.size()+"    total revenue: "+revenue+"");
        
        if(products.size() < 5) {
            notifyAll();
        }
        
    }
}

MarketAction.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
package org.goodsmarket;
 
public class MarketAction {
    
    public static void main(String[] args) {
        
        // shared object
        Store store = new Store();
        
        // threads: 2 suppliers and 1 customer
        Thread sup1 = new Thread(new Supplier("comp1", store));
        Thread sup2 = new Thread(new Supplier("comp2", store));
        Thread cust1 = new Thread(new Customer("John", store));
        
        // start market actions: supplying and sailing
        sup1.start();
        sup2.start();
        cust1.start();
    }
}

Эх, ностальгия, самому приятно было вспомнить

@Skipy · 30.11.2010, 11:05

Сообщение от isakz

да тут потихоньку изучаю wait notify, но пока не сообразил как их использовать в этом примере

Вот это решает задачу: java.util.concurrent.ArrayBlockingQueue

@isakz · 30.11.2010, 12:51 **[ТС]**

aga, spasibo. posmotru.

Новые блоги и статьи Все статьи Все блоги /
Использование SDL3-callbacks вместо функции main() на Android, Desktop и WebAssembly 8Observer8 24.01.2026 Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а привычная функция main(). . .	моя боль iceja 24.01.2026 Выложила интерполяцию кубическими сплайнами www. iceja. net REST сервисы временно не работают, только через Web. Написала за 56 рабочих часов этот сайт с нуля. При помощи perplexity. ai PRO , при. . .	Модель сукцессии микоризы anaschu 24.01.2026 Решили писать научную статью с неким РОманом	http://iceja.net/ математические сервисы iceja 20.01.2026 Обновила свой сайт http:/ / iceja. net/ , приделала Fast Fourier Transform экстраполяцию сигналов. Однако предсказывает далеко не каждый сигнал (см ограничения http:/ / iceja. net/ fourier/ docs ). Также. . .
http://iceja.net/ сервер решения полиномов iceja 18.01.2026 Выкатила http:/ / iceja. net/ сервер решения полиномов (находит действительные корни полиномов методом Штурма). На сайте документация по API, но скажу прямо VPS слабенький и 200 000 полиномов. . .	Расчёт переходных процессов в цепи постоянного тока igorrr37 16.01.2026 / * Дана цепь(не выше 3-го порядка) постоянного тока с элементами R, L, C, k(ключ), U, E, J. Программа находит переходные токи и напряжения на элементах схемы классическим методом(1 и 2 з-ны. . .	Восстановить юзерскрипты Greasemonkey из бэкапа браузера damix 15.01.2026 Если восстановить из бэкапа профиль Firefox после переустановки винды, то список юзерскриптов в Greasemonkey будет пустым. Но восстановить их можно так. Для этого понадобится консольная утилита. . .	Сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/

@isakz 2 / 2 / 0 Регистрация: 23.10.2010 Сообщений: 111

	Синхронизация потоков. 29.11.2010, 17:15. Показов 3275. Ответов 7 Метки нет (Все метки) имеется магазин и две группы постовщиков, товары будут поставлять две группы одновременно. Если магазин заполняется товаром, то происходит приостановка поставок. После продажи какого-либо количество товаров, снова возабновляются поставки. Что то так вот. 0

@andrewkjr 10 / 10 / 0 Регистрация: 25.11.2010 Сообщений: 40
	29.11.2010, 20:50
	да, я с вами согласен... 0

@isakz 2 / 2 / 0 Регистрация: 23.10.2010 Сообщений: 111
	29.11.2010, 20:51 [ТС]
	скучно что ли стало совсем)) 0

@andrewkjr 10 / 10 / 0 Регистрация: 25.11.2010 Сообщений: 40
	29.11.2010, 21:43
	та есть малёхо )) Ну так есть наработки? Вышеописаный процес легко(ну не тривиально) реализуется с помощью wait / notify методов жава потоков... надо просто что начать делать .. ) 0

@isakz 2 / 2 / 0 Регистрация: 23.10.2010 Сообщений: 111
	29.11.2010, 22:01 [ТС]
	да тут потихоньку изучаю wait notify, но пока не сообразил как их использовать в этом примере 0

@isakz 2 / 2 / 0 Регистрация: 23.10.2010 Сообщений: 111
	30.11.2010, 12:51 [ТС]
	aga, spasibo. posmotru. 0