apis/examples_python/warehouse_8py_source.html

가져오기os

가져오기sys

from스레딩가져오기잠금, 스레드

에서게임가져오기GamsWorkspace, GamsException, GamsExceptionExecution, GamsExitCode


GAMS_MODEL ="""

$eolcom //

$SetDDList 창고 저장소 고정 분리 // 허용되는 정의

$창고를 설정하지 않은 경우 $창고를 설정함 10

$스토어가 설정되지 않은 경우 $set 스토어 50

$설정되지 않은 경우 고정됨 $설정됨 고정됨 20

$if set not set disaggregate $set disaggregate 1 // 더 엄격한 bigM 제약에 대한 표시


$ife %store%<=%피망 슬롯% $abort 매장 수 증가 (>%피망 슬롯)


설정

res '응답 코드'

/ 0 보통

1 라이센스 오류

2 해결책 없음

3 기타 오류 /

ares(res) / 3 /

창고 / w1*w%창고% /

저장 / s1*s%store% /;


별칭

(창고,w)

(상점,들);


스칼라 고정 '창고 개설 고정 비용' / %fixed% /;


매개변수

용량(창고)

공급비용(상점,창고);


$eval storeDIVwarehouse trunc(카드(스토어)/카드(창고))


용량(w) = %storeDIVwarehouse% + mod(ord(w), %storeDIVwarehouse%);

supplyCost(s,w) = 1 + mod(ord(s) + 10*ord(w), 100);


변수

열기(창고)

공급(상점,창고)

obj;


바이너리 변수 열기, 공급;


수식

defobj

하나의 창고

defopen(w);


defobj.. obj =e= sum(w,fixed*open(w)) + sum((w,s), SupplyCost(s,w)*supply(s,w));


한 창고.. 합계(w, 공급(들,w)) =e= 1;


defopen(w).. sum(s, 공급(s,w)) =l= open(w)*capacity(w);


$ifthen %disaggregate%==1

방정식 defopen2(s,w);

defopen2(s,w).. 공급(s,w) =l= 개방(w);

$endif


모델 분포 / 모두 /;

mip를 사용하여 distrib min obj를 해결합니다.


$macro setResult(n) 옵션clear=ares; 아레스(n) = 예;


if (distrib.modelstat=%ModelStat.LicensingProblem% 또는

distrib.solvestat=%Solvestat.LicensingProblems%,

setResult('1');

'라이센스 오류' 중단;

);


if (distrib.solvestat<>%SolveStat.NormalCompletion% 또는

distrib.modelstat<>%ModelStat.Optimal% 및

distrib.modelstat<>%ModelStat.IntegerSolution%,

setResult('2');

'해결책 없음' 중단;

);


setResult('0');

"""


defsolve_warehouse(작업 공간, nr_warehouses, 결과, 잠금):

    글로벌상태

    글로벌status_string

    시도해 보세요:

        # GamsOptions를 인스턴스화하고 일부 스칼라를 정의

opt = 작업 공간.add_options()

opt.all_model_types ="복합체"

opt.defines["창고"] = str(nr_warehouses)

opt.defines["상점"] ="65"

opt.defines["고정됨"] ="22"

opt.defines["분리"] ="0"

opt.optcr = 0.0# 최적성을 해결


        # 문자열에서 GamsJob을 생성하고 결과 데이터베이스에 결과 쓰기

작업 = 작업 공간.add_job_from_string(GAMS_MODEL)

job.run(옵션)


        # 데이터베이스 쓰기 작업을 잠가야 함

lock.acquire()

결과["objrep"].add_record(str(nr_warehouses)).value = (

job.out_db["obj"].first_record().level

        )

lock.release()

        for공급_rec에job.out_db["공급"]:

            ifsupply_rec.level > 0.5:

lock.acquire()

결과["공급 지도"].add_record(

(str(nr_warehouses), 공급_rec.key(0), 공급_rec.key(1))

                )

lock.release()

    제외예외ase:

lock.acquire()

        ifisinstance(e, GamsExceptionExecution):

            # 사용자가 트리거한 중단이 있는지 확인하고 사용자 정의 결과를 찾습니다.

            ife.rc == GamsExitCode.ExecutionError:

status_string = (

job.out_db["res"]

.find_record(job.out_db["아레스"].first_record().key(0))

.text

                )

상태 = e.rc

        그밖에:

인쇄(e)

상태 = -1ifisinstance(e, GamsException)그밖에 -2

lock.release()


if__name__ =="__main__":

sys_dir = sys.argv[1]iflen(sys.argv) > 1그밖에 없음

work_dir = sys.argv[2]iflen(sys.argv) > 2그밖에 없음

ws = GamsWorkspace(system_directory=sys_dir, Working_directory=work_dir)


    # 결과에 대한 GamsDatabase 생성

result_db = ws.add_database()

result_db.add_parameter("objrep", 1,"목표 값")

result_db.add_set("공급지도", 3,"레벨에 따른 공급 연결")


status_string =""

상태 = 0


    # 여러 병렬 작업 실행

잠금 = 잠금()

스레드 = []

    foriin범위(10, 22):

t = 스레드(대상=solve_warehouse, args=(ws, i, result_db, lock))

t.start()

threads.append(t)

    fort에스레드:

t.join()

    if상태 > 0:

        올림GamsExceptionExecution(

f"GamsException이 발생했습니다: 피망 슬롯 실행 중 오류: status status_string",

상태,

ws,

        )

    엘리프상태 == -1:

        올림GamsException("GamsException 발생: 피망 슬롯 API 오류", ws)

    엘리프상태 == -2:

        올림예외("오류가 발생했습니다")


    # 결과 데이터베이스를 GDX 파일로 내보내기

result_db.export(os.path.join(os.getcwd(),"result.gdx"))