Multi-threading 자원 공유 및 NullPointerException

[vitacpark]

안녕하세요, 과제 1번 도중 문제가 생겨 질문 올립니다.

    override fun insertAlbums(albumInfos: List<BatchAlbumInfo>) {
        albumInfos.map { albumInfo ->
            threads.submit{
                TransactionTemplate(txManager).executeWithoutResult {
                    processAlbumInfo(albumInfo)
                }
            }
        }
    }

    private fun processAlbumInfo(albumInfo: BatchAlbumInfo) {
        val artistSet = albumInfo.songs.flatMap { it.artists }.toMutableSet().apply { add(albumInfo.artist) }

        val currentArtistSet = artistRepository.findByNameInWithAlbum(artistSet.toList())
        println("\n<${albumInfo.title}> : ${albumInfo.artist} \nartist : " + currentArtistSet.map{it.name}.toString()+"\nartistSet : ${artistSet.toString()}")
        val artistStringToEntity = artistSet.associateWith { artist ->
            currentArtistSet.find { it.name == artist } ?: artistRepository.save(ArtistEntity(name = artist))
        }
   ...

와 같이 코드를 짜보고 있는데, threads.submit 을 포함하지 않았을 땐 정상적으로 코드가 돌아감을 확인했습니다. artistStringToEntity map을 만들어 string을 Entity로 바꾸는 변수를 사용했는데, 어떤 케이스에선 repository의 findByNameIn 함수가 정상적으로 탐색을 성공하고, 어떤 경우에선 실패함을 확인했습니다.

Test 실행 결과

<Strangers> : Kenya Grace 
artist : []
artistSet : [Kenya Grace]

<3D (feat. Jack Harlow)> : 정국 
artist : []
artistSet : [정국, Jack Harlow]

java.lang.NullPointerException
	at com.wafflestudio.seminar.spring2023.admin.AdminBatchServiceTest.json으로_정리된_앨범_데이터를_DB_인서트__배치_작업은_500ms보다_빨리_완료되어야_함$lambda$6(AdminBatchServiceTest.kt:37)
	at ~~~~~

<greedy> : Tate McRae 
artist : [Tate McRae]
artistSet : [Tate McRae]

<For All The Dogs> : Drake 
artist : [Bad Bunny, Drake, J. Cole, SZA]
artistSet : [Drake, Teezo Touchdown, 21 Savage, J. Cole, Yeat, SZA, PARTYNEXTDOOR, Chief Keef, Bad Bunny, Sexyy Red, Lil Yachty]

Tate McRae는 잘 찾는 반면, 정국은 찾지 못하고 있는데, 동시성으로 인해 Repository에 접근하는 함수가 씹혔다..? 라고 판단을 해 제약을 걸어야 하는 것인지, 다른 오류인지 헷갈려 질문 올려봅니다!

[PFCJeong]

안녕하세요~

첨부 주신 코드에는 findByNameIn 함수가 보이지 않습니다. 코드를 조금 더 자세히 올려주세요.

[vitacpark]

interface ArtistRepository : JpaRepository<ArtistEntity, Long> {
    @Query("SELECT a FROM artists a " +
            "JOIN FETCH a.albums aa " +
            "WHERE a.name IN :keywords")
    fun findByNameInWithAlbum(keywords: List<String>): MutableList<ArtistEntity>
} 

과 같이 작성하였습니다!

[PFCJeong]

어디서 NPE가 발생하는 지 모르겠지만,

album을 조인해주고 있는데 join의 성격상 앨범이 없으면 아티스트도 조회가 안될 것 같네요.

굳이 조인을 해오고 싶으시다면 outer join으로 수정해보시면 좋을 것 같습니다.